activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/5] activemq-artemis git commit: NO-JIRA fixing a test
Date Wed, 21 Dec 2016 17:06:56 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 0b131bddf -> 66b24d16c


NO-JIRA fixing a test


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

Branch: refs/heads/master
Commit: 5e4f4aea8296f83f04d23b14b1bb5faf9af08fe2
Parents: 8941f2b
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Wed Dec 21 11:44:52 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Wed Dec 21 12:04:06 2016 -0500

----------------------------------------------------------------------
 .../tests/integration/crossprotocol/OpenWireToAMQPTest.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/5e4f4aea/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
----------------------------------------------------------------------
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
index 752e60a..d432a9a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/crossprotocol/OpenWireToAMQPTest.java
@@ -34,6 +34,7 @@ import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
 import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
 import org.apache.qpid.jms.JmsConnectionFactory;
 import org.junit.After;
+import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -56,11 +57,11 @@ public class OpenWireToAMQPTest extends ActiveMQTestBase {
       super.setUp();
       server = createServer(true, true);
       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);
       server.start();
       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");
    }
 
@@ -93,6 +94,7 @@ public class OpenWireToAMQPTest extends ActiveMQTestBase {
          MessageConsumer consumer = session.createConsumer(queue);
          connection.start();
          ObjectMessage receive = (ObjectMessage) consumer.receive(5000);
+         Assert.assertNotNull(receive);
          list = (ArrayList) receive.getObject();
          assertEquals(list.get(0), "aString");
          connection.close();


Mime
View raw message