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

Adding simple test sending core & consuming OpenWire

This commit is contained in:
Clebert Suconic 2015-08-25 08:31:24 -04:00
parent 54d9a3e9bc
commit 2b45d6eb9e
1 changed files with 41 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/SimpleOpenWireTest.java
View File

@ -31,6 +31,7 @@ import java.util.concurrent.TimeUnit;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.core.settings.impl.AddressSettings; import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic; import org.apache.activemq.command.ActiveMQTopic;
@ -473,4 +474,44 @@ public class SimpleOpenWireTest extends BasicOpenWireTest {
} }
// simple test sending openwire, consuming core
@Test
public void testMixedOpenWireExample2() throws Exception {
Connection conn1 = null;
SimpleString durableQueue = new SimpleString("jms.queue.exampleQueue");
this.server.createQueue(durableQueue, durableQueue, null, true, false);
Queue queue = ActiveMQJMSClient.createQueue("exampleQueue");
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory artemisCF = new org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory();
conn1 = artemisCF.createConnection();
conn1.start();
Session session1 = conn1.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session1.createProducer(queue);
for (int i = 0; i < 10; i++) {
TextMessage message = session1.createTextMessage("This is a text message");
producer.send(message);
}
ActiveMQConnectionFactory openCF = new ActiveMQConnectionFactory();
Connection conn2 = openCF.createConnection();
Session sess2 = conn2.createSession(false, Session.AUTO_ACKNOWLEDGE);
conn2.start();
MessageConsumer messageConsumer = sess2.createConsumer(sess2.createQueue("exampleQueue"));
for (int i = 0; i < 10; i++) {
TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
assertEquals("This is a text message", messageReceived.getText());
}
conn1.close();
conn2.close();
}
} }