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

Fix InterceptorTest

This commit is contained in:
jbertram 2016-05-04 21:25:43 -05:00 committed by Clebert Suconic
parent 28daa6f2df
commit ad24c58c64
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/interceptors/InterceptorTest.java
View File

@ -51,6 +51,7 @@ import org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSen
import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.ServerMessage; import org.apache.activemq.artemis.core.server.ServerMessage;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQDestination;
import org.apache.activemq.artemis.spi.core.protocol.RemotingConnection; import org.apache.activemq.artemis.spi.core.protocol.RemotingConnection;
import org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager; import org.apache.activemq.artemis.spi.core.security.ActiveMQJAASSecurityManager;
import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
@ -64,6 +65,8 @@ public class InterceptorTest extends ActiveMQTestBase {
private final SimpleString QUEUE = new SimpleString("InterceptorTestQueue"); private final SimpleString QUEUE = new SimpleString("InterceptorTestQueue");
private final SimpleString JMS_QUEUE = SimpleString.toSimpleString(ActiveMQDestination.JMS_QUEUE_ADDRESS_PREFIX + QUEUE.toString());
private ServerLocator locator; private ServerLocator locator;
@Override @Override
@ -1056,6 +1059,8 @@ public class InterceptorTest extends ActiveMQTestBase {
public void testInterceptorOnURI() throws Exception { public void testInterceptorOnURI() throws Exception {
locator.close(); locator.close();
server.createQueue(JMS_QUEUE, JMS_QUEUE, null, true, false);
String uri = "tcp://localhost:61616?incomingInterceptorList=" + Incoming.class.getCanonicalName() + "&outgoingInterceptorList=" + Outgoing.class.getName(); String uri = "tcp://localhost:61616?incomingInterceptorList=" + Incoming.class.getCanonicalName() + "&outgoingInterceptorList=" + Outgoing.class.getName();
System.out.println(uri); System.out.println(uri);
@ -1084,7 +1089,7 @@ public class InterceptorTest extends ActiveMQTestBase {
MessageConsumer consumer = session.createConsumer(session.createQueue(QUEUE.toString())); MessageConsumer consumer = session.createConsumer(session.createQueue(QUEUE.toString()));
TextMessage msg = (TextMessage) consumer.receive(5000); TextMessage msg = (TextMessage) consumer.receive(5000);
Assert.assertNotNull(consumer); Assert.assertNotNull(msg);
Assert.assertEquals("HelloMessage", msg.getText()); Assert.assertEquals("HelloMessage", msg.getText());