activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [2/5] activemq-artemis git commit: Fix adding duplicate detection id in Openwire AMQSession.send
Date Fri, 29 Jul 2016 19:35:38 GMT
Fix adding duplicate detection id in Openwire AMQSession.send


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/7ce2d7c1
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/7ce2d7c1
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/7ce2d7c1

Branch: refs/heads/master
Commit: 7ce2d7c199876941b6bc36b02831d77f4fe600db
Parents: af553cc
Author: Ville Skyttä <ville.skytta@iki.fi>
Authored: Fri Jul 29 19:17:59 2016 +0300
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Fri Jul 29 15:35:25 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/core/protocol/openwire/amq/AMQSession.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/7ce2d7c1/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
index 472917d..4e1e8c4 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQSession.java
@@ -271,7 +271,7 @@ public class AMQSession implements SessionCallback {
       * not receive acks will be resent.  (ActiveMQ broker handles this by returning a last
sequence id received to
       * the client).  To handle this in Artemis we use a duplicate ID cache.  To do this
we check to see if the
       * message comes from failover connection.  If so we add a DUPLICATE_ID to handle duplicates
after a resend. */
-      if (connection.getContext().isFaultTolerant() && !messageSend.getProperties().containsKey(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID))
{
+      if (connection.getContext().isFaultTolerant() && !messageSend.getProperties().containsKey(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID.toString()))
{
          originalCoreMsg.putStringProperty(org.apache.activemq.artemis.api.core.Message.HDR_DUPLICATE_DETECTION_ID.toString(),
messageSend.getMessageId().toString());
       }
 


Mime
View raw message