summaryrefslogtreecommitdiff
path: root/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java')
-rw-r--r--trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java310
1 files changed, 0 insertions, 310 deletions
diff --git a/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java b/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java
deleted file mode 100644
index a09589b121..0000000000
--- a/trunk/qpid/java/systests/src/main/java/org/apache/qpid/test/client/message/SelectorTest.java
+++ /dev/null
@@ -1,310 +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 java.util.concurrent.CountDownLatch;
-
-import javax.jms.DeliveryMode;
-import javax.jms.InvalidSelectorException;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageListener;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
-
-import junit.framework.Assert;
-
-import org.apache.qpid.AMQException;
-import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.client.AMQDestination;
-import org.apache.qpid.client.AMQQueue;
-import org.apache.qpid.client.AMQSession;
-import org.apache.qpid.client.BasicMessageProducer;
-import org.apache.qpid.test.utils.QpidTestCase;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class SelectorTest extends QpidTestCase implements MessageListener
-{
- private static final Logger _logger = LoggerFactory.getLogger(SelectorTest.class);
-
- private AMQConnection _connection;
- private AMQDestination _destination;
- private int count;
- public String _connectionString = "vm://:1";
- private static final String INVALID_SELECTOR = "Cost LIKE 5";
- CountDownLatch _responseLatch = new CountDownLatch(1);
-
- private static final String BAD_MATHS_SELECTOR = " 1 % 5";
-
- private static final long RECIEVE_TIMEOUT = 1000;
-
- protected void setUp() throws Exception
- {
- super.setUp();
- init((AMQConnection) getConnection("guest", "guest"));
- }
-
- private void init(AMQConnection connection) throws JMSException
- {
- init(connection, new AMQQueue(connection, getTestQueueName(), true));
- }
-
- private void init(AMQConnection connection, AMQDestination destination) throws JMSException
- {
- _connection = connection;
- _destination = destination;
- connection.start();
- }
-
- public void onMessage(Message message)
- {
- count++;
- _logger.info("Got Message:" + message);
- _responseLatch.countDown();
- }
-
- public void testUsingOnMessage() throws Exception
- {
- String selector = "Cost = 2 AND \"property-with-hyphen\" = 'wibble'";
- // selector = "JMSType = Special AND Cost = 2 AND AMQMessageID > 0 AND JMSDeliveryMode=" + DeliveryMode.NON_PERSISTENT;
-
- Session session = (AMQSession) _connection.createSession(false, AMQSession.NO_ACKNOWLEDGE);
- // _session.createConsumer(destination).setMessageListener(this);
- session.createConsumer(_destination, selector).setMessageListener(this);
-
- try
- {
- Message msg = session.createTextMessage("Message");
- msg.setJMSPriority(1);
- msg.setIntProperty("Cost", 2);
- msg.setStringProperty("property-with-hyphen", "wibble");
- msg.setJMSType("Special");
-
- _logger.info("Sending Message:" + msg);
-
- ((BasicMessageProducer) session.createProducer(_destination)).send(msg, DeliveryMode.NON_PERSISTENT);
- _logger.info("Message sent, waiting for response...");
-
- _responseLatch.await();
-
- if (count > 0)
- {
- _logger.info("Got message");
- }
-
- if (count == 0)
- {
- fail("Did not get message!");
- // throw new RuntimeException("Did not get message!");
- }
- }
- catch (JMSException e)
- {
- _logger.debug("JMS:" + e.getClass().getSimpleName() + ":" + e.getMessage());
- if (!(e instanceof InvalidSelectorException))
- {
- fail("Wrong exception:" + e.getMessage());
- }
- else
- {
- System.out.println("SUCCESS!!");
- }
- }
- catch (InterruptedException e)
- {
- _logger.debug("IE :" + e.getClass().getSimpleName() + ":" + e.getMessage());
- }
-
- }
-
- public void testUnparsableSelectors() throws Exception
- {
- AMQSession session = (AMQSession) _connection.createSession(false, AMQSession.NO_ACKNOWLEDGE);
- boolean caught = false;
-
- //Try Creating a Browser
- try
- {
- session.createBrowser(session.createQueue("Ping"), INVALID_SELECTOR);
- }
- catch (JMSException e)
- {
- _logger.debug("JMS:" + e.getClass().getSimpleName() + ":" + e.getMessage());
- if (!(e instanceof InvalidSelectorException))
- {
- fail("Wrong exception:" + e.getMessage());
- }
- caught = true;
- }
- assertTrue("No exception thrown!", caught);
- caught = false;
-
- //Try Creating a Consumer
- try
- {
- session.createConsumer(session.createQueue("Ping"), INVALID_SELECTOR);
- }
- catch (JMSException e)
- {
- _logger.debug("JMS:" + e.getClass().getSimpleName() + ":" + e.getMessage());
- if (!(e instanceof InvalidSelectorException))
- {
- fail("Wrong exception:" + e.getMessage());
- }
- caught = true;
- }
- assertTrue("No exception thrown!", caught);
- caught = false;
-
- //Try Creating a Receiever
- try
- {
- session.createReceiver(session.createQueue("Ping"), INVALID_SELECTOR);
- }
- catch (JMSException e)
- {
- _logger.debug("JMS:" + e.getClass().getSimpleName() + ":" + e.getMessage());
- if (!(e instanceof InvalidSelectorException))
- {
- fail("Wrong exception:" + e.getMessage());
- }
- caught = true;
- }
- assertTrue("No exception thrown!", caught);
- caught = false;
-
- try
- {
- session.createReceiver(session.createQueue("Ping"), BAD_MATHS_SELECTOR);
- }
- catch (JMSException e)
- {
- _logger.debug("JMS:" + e.getClass().getSimpleName() + ":" + e.getMessage());
- if (!(e instanceof InvalidSelectorException))
- {
- fail("Wrong exception:" + e.getMessage());
- }
- caught = true;
- }
- assertTrue("No exception thrown!", caught);
- caught = false;
-
- }
-
- public void testRuntimeSelectorError() throws JMSException
- {
- Session session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- MessageConsumer consumer = session.createConsumer(_destination , "testproperty % 5 = 1");
- MessageProducer producer = session.createProducer(_destination);
- Message sentMsg = session.createTextMessage();
-
- sentMsg.setIntProperty("testproperty", 1); // 1 % 5
- producer.send(sentMsg);
- Message recvd = consumer.receive(RECIEVE_TIMEOUT);
- assertNotNull(recvd);
-
- sentMsg.setStringProperty("testproperty", "hello"); // "hello" % 5 makes no sense
- producer.send(sentMsg);
- try
- {
- recvd = consumer.receive(RECIEVE_TIMEOUT);
- assertNull(recvd);
- }
- catch (Exception e)
- {
-
- }
- assertTrue("Connection should be closed", _connection.isClosed());
- }
-
- public void testSelectorWithJMSMessageID() throws Exception
- {
- Session session = _connection.createSession(true, Session.SESSION_TRANSACTED);
-
- MessageProducer prod = session.createProducer(_destination);
- MessageConsumer consumer = session.createConsumer(_destination,"JMSMessageID IS NOT NULL");
-
- for (int i=0; i<2; i++)
- {
- Message msg = session.createTextMessage("Msg" + String.valueOf(i));
- prod.send(msg);
- }
- session.commit();
-
- Message msg1 = consumer.receive(1000);
- Message msg2 = consumer.receive(1000);
-
- Assert.assertNotNull("Msg1 should not be null", msg1);
- Assert.assertNotNull("Msg2 should not be null", msg2);
-
- session.commit();
-
- prod.setDisableMessageID(true);
-
- for (int i=0; i<2; i++)
- {
- Message msg = session.createTextMessage("Msg" + String.valueOf(i));
- prod.send(msg);
- }
-
- session.commit();
- Message msg3 = consumer.receive(1000);
- Assert.assertNull("Msg3 should be null", msg3);
- session.commit();
- consumer = session.createConsumer(_destination,"JMSMessageID IS NULL");
-
- Message msg4 = consumer.receive(1000);
- Message msg5 = consumer.receive(1000);
- session.commit();
- Assert.assertNotNull("Msg4 should not be null", msg4);
- Assert.assertNotNull("Msg5 should not be null", msg5);
- }
-
- public static void main(String[] argv) throws Exception
- {
- SelectorTest test = new SelectorTest();
- test._connectionString = (argv.length == 0) ? "localhost:3000" : argv[0];
-
- try
- {
- while (true)
- {
- if (test._connectionString.contains("vm://:1"))
- {
- test.setUp();
- }
- test.testUsingOnMessage();
-
- if (test._connectionString.contains("vm://:1"))
- {
- test.tearDown();
- }
- }
- }
- catch (Exception e)
- {
- System.err.println(e.getMessage());
- e.printStackTrace();
- }
- }
-}
View Lorry Controller Status