diff options
Diffstat (limited to 'deps/rabbitmq_amqp1_0/test/system_SUITE_data/java-tests/src/test/java/com')
-rw-r--r-- | deps/rabbitmq_amqp1_0/test/system_SUITE_data/java-tests/src/test/java/com/rabbitmq/amqp1_0/tests/jms/RoundTripTest.java | 84 |
1 files changed, 84 insertions, 0 deletions
diff --git a/deps/rabbitmq_amqp1_0/test/system_SUITE_data/java-tests/src/test/java/com/rabbitmq/amqp1_0/tests/jms/RoundTripTest.java b/deps/rabbitmq_amqp1_0/test/system_SUITE_data/java-tests/src/test/java/com/rabbitmq/amqp1_0/tests/jms/RoundTripTest.java new file mode 100644 index 0000000000..db5850f8bf --- /dev/null +++ b/deps/rabbitmq_amqp1_0/test/system_SUITE_data/java-tests/src/test/java/com/rabbitmq/amqp1_0/tests/jms/RoundTripTest.java @@ -0,0 +1,84 @@ +// vim:sw=4:et: + +package com.rabbitmq.amqp1_0.tests.jms; + +import java.util.*; + +import junit.framework.Test; +import junit.framework.TestCase; +import junit.framework.TestSuite; + +import javax.jms.Connection; +import javax.jms.ConnectionFactory; +import javax.jms.DeliveryMode; +import javax.jms.Destination; +import javax.jms.ExceptionListener; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.naming.Context; +import javax.naming.InitialContext; + +/** + * Unit test for simple App. + */ +public class RoundTripTest + extends TestCase +{ + public static final String ADDRESS = "/jms-roundtrip-q"; + public static final String PAYLOAD = "Payload"; + + /** + * Create the test case + * + * @param testName name of the test case + */ + public RoundTripTest(String testName) + { + super(testName); + } + + /** + * @return the suite of tests being tested + */ + public static Test suite() + { + return new TestSuite(RoundTripTest.class); + } + + public void test_roundtrip () throws Exception + { + String uri = System.getProperty("rmq_broker_uri"); + String address = uri + ADDRESS; + Hashtable<Object, Object> env = new Hashtable<Object, Object>(); + env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory"); + env.put("connectionfactory.myFactoryLookup", uri); + env.put("queue.myQueueLookup", "my-queue"); + env.put("jms.sendTimeout", 5); + env.put("jms.requestTimeout", 5); + javax.naming.Context context = new javax.naming.InitialContext(env); + + assertNotNull(uri); + + ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup"); + Destination queue = (Destination) context.lookup("myQueueLookup"); + + Connection connection = factory.createConnection("guest", "guest"); + connection.start(); + + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageProducer messageProducer = session.createProducer(queue); + MessageConsumer messageConsumer = session.createConsumer(queue); + + TextMessage message = session.createTextMessage("Hello world!"); + messageProducer.send(message, DeliveryMode.NON_PERSISTENT, + Message.DEFAULT_PRIORITY, Message.DEFAULT_TIME_TO_LIVE); + TextMessage receivedMessage = (TextMessage) messageConsumer.receive(2000L); + + assertEquals(message.getText(), receivedMessage.getText()); + } +} |