activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq-artemis git commit: ARTEMIS-2103 - fix up test to reflect full consumer queue name in the fqqn queue
Date Thu, 11 Oct 2018 16:05:59 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 67d493ee0 -> 202ae262d


ARTEMIS-2103 - fix up test to reflect full consumer queue name in the fqqn queue


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

Branch: refs/heads/master
Commit: 202ae262d342f4660bdc2b98eb2a3e5508803246
Parents: 67d493e
Author: gtully <gary.tully@gmail.com>
Authored: Thu Oct 11 17:04:30 2018 +0100
Committer: gtully <gary.tully@gmail.com>
Committed: Thu Oct 11 17:05:32 2018 +0100

----------------------------------------------------------------------
 .../core/protocol/openwire/OpenWireProtocolManagerTest.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/202ae262/tests/integration-tests/src/test/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerTest.java
index 85b5685..2d87a53 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerTest.java
@@ -50,13 +50,13 @@ public class OpenWireProtocolManagerTest {
       underTest.setVirtualTopicConsumerWildcards("A.>;1,B.*.>;2,C.*.*.*.EE;3");
 
       ActiveMQDestination A = new org.apache.activemq.command.ActiveMQQueue("A.SomeTopic");
-      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic::A"), underTest.virtualTopicConsumerToFQQN(A));
+      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic::A.SomeTopic"),
underTest.virtualTopicConsumerToFQQN(A));
 
       ActiveMQDestination B = new org.apache.activemq.command.ActiveMQQueue("B.b.SomeTopic.B");
-      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic.B::B.b"), underTest.virtualTopicConsumerToFQQN(B));
+      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic.B::B.b.SomeTopic.B"),
underTest.virtualTopicConsumerToFQQN(B));
 
       ActiveMQDestination C = new org.apache.activemq.command.ActiveMQQueue("C.c.c.SomeTopic.EE");
-      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic.EE::C.c.c"),
underTest.virtualTopicConsumerToFQQN(C));
+      assertEquals(new org.apache.activemq.command.ActiveMQQueue("SomeTopic.EE::C.c.c.SomeTopic.EE"),
underTest.virtualTopicConsumerToFQQN(C));
 
       for (int i = 0; i < maxCacheSize; i++) {
          ActiveMQDestination identity = new org.apache.activemq.command.ActiveMQQueue("Identity"
+ i);


Mime
View raw message