Github user tabish121 commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1558#discussion_r141408505
--- Diff:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ConsumerTest.java
---
@@ -231,6 +231,35 @@ public void testSendAMQPReceiveCore() throws Throwable
{
}
@Test
+ public void testAutoCreateMulticastQueue() throws Throwable {
+ if (!isNetty()) {
+ // no need to run the test, there's no AMQP support
+ return;
+ }
+
+
assertNull(server.getAddressInfo(SimpleString.toSimpleString("topic")));
+
+ ConnectionFactory factorySend = createFactory(2);
+ Connection connection = factorySend.createConnection();
+
+ try {
+ Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
+ javax.jms.Topic queue = session.createTopic("topic");
--- End diff --
Your destination variable name is a bit confusing.
---
