Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

The testWildcardConsume has 1 consumer subscribe to 2 destiantions and made an assumption 

that messages would delivered in the order published to the 2 different destinations.  This is not correct
as the messages could queue up and get dispatched at different times.  Updated the code so that this assumption
is no longer relied on.


git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@633554 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2008-03-04 17:28:53 +00:00
parent 3d18d59904
commit 1c8cfd9cfe
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
View File

@ -839,14 +839,15 @@ public class BrokerTest extends BrokerTestSupport {
// These two message should match the wild card. // These two message should match the wild card.
ActiveMQDestination d1 = ActiveMQDestination.createDestination("WILD.CARD.TEST", destinationType); ActiveMQDestination d1 = ActiveMQDestination.createDestination("WILD.CARD.TEST", destinationType);
connection1.send(createMessage(producerInfo1, d1, deliveryMode)); connection1.send(createMessage(producerInfo1, d1, deliveryMode));
ActiveMQDestination d2 = ActiveMQDestination.createDestination("WILD.FOO.TEST", destinationType);
connection1.request(createMessage(producerInfo1, d2, deliveryMode));
Message m = receiveMessage(connection1); Message m = receiveMessage(connection1);
assertNotNull(m); assertNotNull(m);
//assertEquals(d1, m.getDestination()); assertEquals(d1, m.getDestination());
ActiveMQDestination d2 = ActiveMQDestination.createDestination("WILD.FOO.TEST", destinationType);
connection1.request(createMessage(producerInfo1, d2, deliveryMode));
m = receiveMessage(connection1); m = receiveMessage(connection1);
//assertNotNull(m); assertNotNull(m);
assertEquals(d2, m.getDestination()); assertEquals(d2, m.getDestination());
assertNoMessagesLeft(connection1); assertNoMessagesLeft(connection1);