mirror of
https://github.com/apache/activemq-artemis.git
synced 2025-02-22 02:05:13 +00:00
ARTEMIS-2504 fix divert test
This commit is contained in:
parent
c881158de1
commit
ea0047a1b4
@ -169,7 +169,7 @@ public class DivertTest extends ActiveMQTestBase {
|
|||||||
|
|
||||||
session.createQueue(new SimpleString(testForConvert), RoutingType.ANYCAST, SimpleString.toSimpleString(testForConvert), null, true);
|
session.createQueue(new SimpleString(testForConvert), RoutingType.ANYCAST, SimpleString.toSimpleString(testForConvert), null, true);
|
||||||
|
|
||||||
session.createQueue(new SimpleString(forwardAddress), RoutingType.MULTICAST, queueName2, null, true);
|
session.createQueue(new SimpleString(forwardAddress), RoutingType.ANYCAST, queueName2, null, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
ConnectionFactory coreCF = CFUtil.createConnectionFactory("CORE", "tcp://localhost:61616");
|
ConnectionFactory coreCF = CFUtil.createConnectionFactory("CORE", "tcp://localhost:61616");
|
||||||
|
Loading…
x
Reference in New Issue
Block a user