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 <[email protected]> Authored: Wed Nov 19 17:46:33 2014 -0500 Committer: Clebert Suconic <[email protected]> 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 // -----------------------------------------------------------------------------------
