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

NO-JIRA fixing a test

This commit is contained in:
Clebert Suconic 2016-12-21 11:44:52 -05:00
parent 8941f2b15d
commit 5e4f4aea82
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
View File

@ -34,6 +34,7 @@ import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
import org.apache.qpid.jms.JmsConnectionFactory; import org.apache.qpid.jms.JmsConnectionFactory;
import org.junit.After; import org.junit.After;
import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -56,11 +57,11 @@ public class OpenWireToAMQPTest extends ActiveMQTestBase {
super.setUp(); super.setUp();
server = createServer(true, true); server = createServer(true, true);
Configuration serverConfig = server.getConfiguration(); Configuration serverConfig = server.getConfiguration();
serverConfig.getAddressesSettings().put("#", new AddressSettings().setAutoCreateQueues(false).setAutoCreateAddresses(false).setDeadLetterAddress(new SimpleString("ActiveMQ.DLQ"))); serverConfig.getAddressesSettings().put("#", new AddressSettings().setAutoCreateQueues(true).setAutoCreateAddresses(true).setDeadLetterAddress(new SimpleString("ActiveMQ.DLQ")));
serverConfig.setSecurityEnabled(false); serverConfig.setSecurityEnabled(false);
server.start(); server.start();
coreQueue = new SimpleString(queueName); coreQueue = new SimpleString(queueName);
this.server.createQueue(coreQueue, RoutingType.MULTICAST, coreQueue, null, false, false); this.server.createQueue(coreQueue, RoutingType.MULTICAST, coreQueue, null, false, false, -1, false, true);
qpidfactory = new JmsConnectionFactory("amqp://localhost:61616"); qpidfactory = new JmsConnectionFactory("amqp://localhost:61616");
} }
@ -93,6 +94,7 @@ public class OpenWireToAMQPTest extends ActiveMQTestBase {
MessageConsumer consumer = session.createConsumer(queue); MessageConsumer consumer = session.createConsumer(queue);
connection.start(); connection.start();
ObjectMessage receive = (ObjectMessage) consumer.receive(5000); ObjectMessage receive = (ObjectMessage) consumer.receive(5000);
Assert.assertNotNull(receive);
list = (ArrayList) receive.getObject(); list = (ArrayList) receive.getObject();
assertEquals(list.get(0), "aString"); assertEquals(list.get(0), "aString");
connection.close(); connection.close();