diff options
Diffstat (limited to 'trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/JMSDestinationTest.java')
| -rw-r--r-- | trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/JMSDestinationTest.java | 330 |
1 files changed, 0 insertions, 330 deletions
diff --git a/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/JMSDestinationTest.java b/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/JMSDestinationTest.java deleted file mode 100644 index 60db1a25d7..0000000000 --- a/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/JMSDestinationTest.java +++ /dev/null @@ -1,330 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - * - */ -package org.apache.qpid.test.client.message; - -import org.apache.qpid.client.AMQDestination; -import org.apache.qpid.client.AMQTopic; -import org.apache.qpid.client.CustomJMSXProperty; -import org.apache.qpid.client.configuration.ClientProperties; -import org.apache.qpid.management.common.mbeans.ManagedQueue; -import org.apache.qpid.test.utils.JMXTestUtils; -import org.apache.qpid.test.utils.QpidTestCase; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.Message; -import javax.jms.MessageConsumer; -import javax.jms.MessageListener; -import javax.jms.MessageProducer; -import javax.jms.Queue; -import javax.jms.Session; -import javax.jms.Topic; -import javax.management.openmbean.CompositeDataSupport; -import javax.management.openmbean.TabularData; -import java.nio.BufferOverflowException; -import java.util.Iterator; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.TimeUnit; - -/** - * From the API Docs getJMSDestination: - * - * When a message is received, its JMSDestination value must be equivalent to - * the value assigned when it was sent. - */ -public class JMSDestinationTest extends QpidTestCase -{ - - private Connection _connection; - private Session _session; - - private static final String USER = "admin"; - private CountDownLatch _receiveMessage; - private Message _message; - - public void setUp() throws Exception - { - //Ensure JMX management is enabled for MovedToQueue test - setConfigurationProperty("management.enabled", "true"); - - super.setUp(); - - _connection = getConnection(); - - _session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - } - - /** - * Test a message sent to a queue comes back with JMSDestination queue - * - * @throws Exception - */ - public void testQueue() throws Exception - { - - Queue queue = _session.createQueue(getTestQueueName()); - - MessageConsumer consumer = _session.createConsumer(queue); - - sendMessage(_session, queue, 1); - - _connection.start(); - - Message message = consumer.receive(10000); - - assertNotNull("Message should not be null", message); - - Destination destination = message.getJMSDestination(); - - assertNotNull("JMSDestination should not be null", destination); - - assertEquals("Incorrect Destination type", queue.getClass(), destination.getClass()); - } - - /** - * Test a message sent to a topic comes back with JMSDestination topic - * - * @throws Exception - */ - public void testTopic() throws Exception - { - - Topic topic = _session.createTopic(getTestQueueName() + "Topic"); - - MessageConsumer consumer = _session.createConsumer(topic); - - sendMessage(_session, topic, 1); - - _connection.start(); - - Message message = consumer.receive(10000); - - assertNotNull("Message should not be null", message); - - Destination destination = message.getJMSDestination(); - - assertNotNull("JMSDestination should not be null", destination); - - assertEquals("Incorrect Destination type", topic.getClass(), destination.getClass()); - } - - /** - * Test a message sent to a topic then moved on the broker - * comes back with JMSDestination queue. - * - * i.e. The client is not just setting the value to be the same as the - * current consumer destination. - * - * This test can only be run against the Java broker as it uses JMX to move - * messages between queues. - * - * @throws Exception - */ - public void testMovedToQueue() throws Exception - { - // Setup JMXUtils - JMXTestUtils jmxUtils = new JMXTestUtils(this, USER, USER); - jmxUtils.setUp(); - // Open the JMX Connection - jmxUtils.open(); - try - { - - Queue queue = _session.createQueue(getTestQueueName()); - - _session.createConsumer(queue).close(); - - sendMessage(_session, queue, 1); - - Topic topic = _session.createTopic(getTestQueueName() + "Topic"); - - MessageConsumer consumer = _session.createConsumer(topic); - - // Use Management to move message. - - ManagedQueue managedQueue = jmxUtils. - getManagedObject(ManagedQueue.class, - jmxUtils.getQueueObjectName(getConnectionFactory().getVirtualPath().substring(1), - getTestQueueName())); - - // Find the first message on the queue - TabularData data = managedQueue.viewMessages(1L, 2L); - - Iterator values = data.values().iterator(); - assertTrue("No Messages found via JMX", values.hasNext()); - - // Get its message ID - Long msgID = (Long) ((CompositeDataSupport) values.next()).get("AMQ MessageId"); - - // Start the connection and consume message that has been moved to the - // queue - _connection.start(); - - Message message = consumer.receive(1000); - - //Validate we don't have a message on the queue before we start - assertNull("Message should be null", message); - - // Move it to from the topic to the queue - managedQueue.moveMessages(msgID, msgID, ((AMQTopic) topic).getQueueName()); - - // Retrieve the newly moved message - message = consumer.receive(1000); - - assertNotNull("Message should not be null", message); - - Destination destination = message.getJMSDestination(); - - assertNotNull("JMSDestination should not be null", destination); - - assertEquals("Incorrect Destination type", queue.getClass(), destination.getClass()); - - } - finally - { - jmxUtils.close(); - } - - } - - /** - * Test a message sent to a queue comes back with JMSDestination queue - * when received via a message listener - * - * @throws Exception - */ - public void testQueueAsync() throws Exception - { - - Queue queue = _session.createQueue(getTestQueueName()); - - MessageConsumer consumer = _session.createConsumer(queue); - - sendMessage(_session, queue, 1); - - _connection.start(); - - _message = null; - _receiveMessage = new CountDownLatch(1); - - consumer.setMessageListener(new MessageListener() - { - public void onMessage(Message message) - { - _message = message; - _receiveMessage.countDown(); - } - }); - - assertTrue("Timed out waiting for message to be received ", _receiveMessage.await(1, TimeUnit.SECONDS)); - - assertNotNull("Message should not be null", _message); - - Destination destination = _message.getJMSDestination(); - - assertNotNull("JMSDestination should not be null", destination); - - assertEquals("Incorrect Destination type", queue.getClass(), destination.getClass()); - } - - /** - * Test a message received without the JMS_QPID_DESTTYPE can be resent - * and correctly have the property set. - * - * To do this we need to create a 0-10 connection and send a message - * which is then received by a 0-8/9 client. - * - * @throws Exception - */ - public void testReceiveResend() throws Exception - { - // Create a 0-10 Connection and send message - setSystemProperty(ClientProperties.AMQP_VERSION, "0-10"); - - Connection connection010 = getConnection(); - - Session session010 = connection010.createSession(true, Session.SESSION_TRANSACTED); - - // Create queue for testing - Queue queue = session010.createQueue(getTestQueueName()); - - // Ensure queue exists - session010.createConsumer(queue).close(); - - sendMessage(session010, queue, 1); - - // Close the 010 connection - connection010.close(); - - // Create a 0-8 Connection and receive message - setSystemProperty(ClientProperties.AMQP_VERSION, "0-8"); - - Connection connection08 = getConnection(); - - Session session08 = connection08.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageConsumer consumer = session08.createConsumer(queue); - - connection08.start(); - - Message message = consumer.receive(1000); - - assertNotNull("Didn't receive 0-10 message.", message); - - // Validate that JMS_QPID_DESTTYPE is not set - try - { - message.getIntProperty(CustomJMSXProperty.JMS_QPID_DESTTYPE.toString()); - fail("JMS_QPID_DESTTYPE should not be set, so should throw NumberFormatException"); - } - catch (NumberFormatException nfe) - { - - } - - // Resend message back to queue and validate that - // a) getJMSDestination works without the JMS_QPID_DESTTYPE - // b) we can actually send without a BufferOverFlow. - - MessageProducer producer = session08.createProducer(queue); - - try - { - producer.send(message); - } - catch (BufferOverflowException bofe) - { - // Print the stack trace so we can validate where the execption occured. - bofe.printStackTrace(); - fail("BufferOverflowException thrown during send"); - } - - message = consumer.receive(1000); - - assertNotNull("Didn't receive recent 0-8 message.", message); - - // Validate that JMS_QPID_DESTTYPE is not set - assertEquals("JMS_QPID_DESTTYPE should be set to a Queue", AMQDestination.QUEUE_TYPE, - message.getIntProperty(CustomJMSXProperty.JMS_QPID_DESTTYPE.toString())); - - } - -} |