Repository: activemq-artemis Updated Branches: refs/heads/2.6.x 8ac9f8d30 -> e4744c903
ARTEMIS-2139 Fix ReplyTo for TempTopic Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/e4744c90 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/e4744c90 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/e4744c90 Branch: refs/heads/2.6.x Commit: e4744c90381d9afc6d2a5275e5e25b26cd22a647 Parents: 8ac9f8d Author: Martyn Taylor <[email protected]> Authored: Tue Oct 30 15:42:02 2018 +0000 Committer: Martyn Taylor <[email protected]> Committed: Tue Oct 30 15:42:02 2018 +0000 ---------------------------------------------------------------------- .../org/apache/activemq/artemis/jms/client/ActiveMQMessage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/e4744c90/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java ---------------------------------------------------------------------- diff --git a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java index 31631e3..83fffc0 100644 --- a/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java +++ b/artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQMessage.java @@ -393,7 +393,7 @@ public class ActiveMQMessage implements javax.jms.Message { address = TEMP_QUEUE_QUALIFED_PREFIX + PacketImpl.OLD_TEMP_QUEUE_PREFIX + address.substring(TEMP_QUEUE_QUALIFED_PREFIX.length()); } } else if (address.startsWith(TEMP_TOPIC_QUALIFED_PREFIX)) { - if (!address.startsWith(TEMP_TOPIC_QUALIFED_PREFIX + PacketImpl.OLD_TOPIC_PREFIX.toString())) { + if (!address.startsWith(TEMP_TOPIC_QUALIFED_PREFIX + PacketImpl.OLD_TEMP_TOPIC_PREFIX.toString())) { address = TEMP_TOPIC_QUALIFED_PREFIX + PacketImpl.OLD_TEMP_TOPIC_PREFIX + address.substring(TEMP_TOPIC_QUALIFED_PREFIX.length()); } } else if (address.startsWith(PacketImpl.OLD_QUEUE_PREFIX.toString())) {
