Repository: activemq-artemis Updated Branches: refs/heads/2.6.x f4e294289 -> 65213ebef
ARTEMIS-2139 Do not add prefix for temp queues Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/65213ebe Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/65213ebe Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/65213ebe Branch: refs/heads/2.6.x Commit: 65213ebeffb4725c0d926d64c9a85a07af0d89e1 Parents: f4e2942 Author: Martyn Taylor <mtay...@redhat.com> Authored: Sun Nov 4 13:32:29 2018 +0000 Committer: Martyn Taylor <mtay...@redhat.com> Committed: Sun Nov 4 15:44:44 2018 +0000 ---------------------------------------------------------------------- .../org/apache/activemq/artemis/jms/client/ActiveMQMessage.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/65213ebe/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 83fffc0..fb0574e 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 @@ -388,10 +388,6 @@ public class ActiveMQMessage implements javax.jms.Message { if (!address.startsWith(TOPIC_QUALIFIED_PREFIX + PacketImpl.OLD_TOPIC_PREFIX.toString())) { address = TOPIC_QUALIFIED_PREFIX + PacketImpl.OLD_TOPIC_PREFIX + address.substring(TOPIC_QUALIFIED_PREFIX.length()); } - } else if (address.startsWith(TEMP_QUEUE_QUALIFED_PREFIX)) { - if (!address.startsWith(TEMP_QUEUE_QUALIFED_PREFIX + PacketImpl.OLD_TEMP_QUEUE_PREFIX.toString())) { - 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_TEMP_TOPIC_PREFIX.toString())) { address = TEMP_TOPIC_QUALIFED_PREFIX + PacketImpl.OLD_TEMP_TOPIC_PREFIX + address.substring(TEMP_TOPIC_QUALIFED_PREFIX.length());