activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From andytay...@apache.org
Subject [8/9] activemq-6 git commit: Renaming ClientConsumer/hornetq property, with adding a todo block https://issues.apache.org/jira/browse/ACTIVEMQ6-42
Date Thu, 20 Nov 2014 08:57:53 GMT
Renaming ClientConsumer/hornetq property, with adding a todo block
https://issues.apache.org/jira/browse/ACTIVEMQ6-42

we need to make sure the ClientConsumerImpl.forced_delivery_message
property is correctly dealt with.


Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/9b828d2d
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/9b828d2d
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/9b828d2d

Branch: refs/heads/master
Commit: 9b828d2d49e5c19a4b6d924fe381ce54f7999624
Parents: 89a84c6
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Wed Nov 19 17:46:33 2014 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Wed Nov 19 17:46:40 2014 -0500

----------------------------------------------------------------------
 .../apache/activemq/core/client/impl/ClientConsumerImpl.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-6/blob/9b828d2d/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java
----------------------------------------------------------------------
diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java
b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java
index 6295a74..c17907f 100644
--- a/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java
+++ b/activemq-core-client/src/main/java/org/apache/activemq/core/client/impl/ClientConsumerImpl.java
@@ -59,7 +59,10 @@ public final class ClientConsumerImpl implements ClientConsumerInternal
 
    private static final int NUM_PRIORITIES = 10;
 
-   public static final SimpleString FORCED_DELIVERY_MESSAGE = new SimpleString("_hornetq.forced.delivery.seq");
+
+   // TODO: We need to set this to _hornetq | activemq based on the version of the protocol
+   // I have added a comment about this at https://issues.apache.org/jira/browse/ACTIVEMQ6-42
+   public static final SimpleString FORCED_DELIVERY_MESSAGE = new SimpleString("_activemq.forced.delivery.seq");
 
    // Attributes
    // -----------------------------------------------------------------------------------


Mime
View raw message