[hornetq-commits] JBoss hornetq SVN: r9548 - trunk/tests/src/org/hornetq/tests/integration/client.
Author: clebert.suconic(a)jboss.com
Date: 2010-08-13 16:33:24 -0400 (Fri, 13 Aug 2010)
New Revision: 9548
Modified:
trunk/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java
Log:
HORNETQ-477 - Adding commented out tests
Modified: trunk/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java 2010-08-13
18:42:27 UTC (rev 9547)
+++
trunk/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java 2010-08-13
20:33:24 UTC (rev 9548)
@@ -180,6 +180,95 @@
session.close();
}
+
+ public void _testQueueWithWildcard() throws Exception
+ {
+ session.createQueue("a.b", "queue1");
+ session.createTemporaryQueue("a.#", "queue2");
+ session.createTemporaryQueue("a.#", "queue3");
+
+ ClientProducer producer = session.createProducer("a.b");
+ producer.send(session.createMessage(false));
+
+ ClientConsumer cons = session.createConsumer("queue2");
+
+ session.start();
+
+ ClientMessage msg = cons.receive(5000);
+
+ assertNotNull(msg);
+
+ msg.acknowledge();
+
+ cons.close();
+
+ cons = session.createConsumer("queue3");
+
+ session.start();
+
+ msg = cons.receive(5000);
+
+ assertNotNull(msg);
+
+ msg.acknowledge();
+
+ cons.close();
+
+ session.deleteQueue("queue2");
+ session.deleteQueue("queue3");
+
+ session.close();
+ }
+
+
+ public void _testQueueWithWildcard2() throws Exception
+ {
+ session.createQueue("a.b", "queue1");
+ session.createTemporaryQueue("a.#", "queue2");
+ session.createTemporaryQueue("a.#", "queue3");
+
+ ClientProducer producer = session.createProducer("a.b");
+ producer.send(session.createMessage(false));
+
+ ClientConsumer cons = session.createConsumer("queue2");
+
+ session.start();
+
+ ClientMessage msg = cons.receive(5000);
+
+ assertNotNull(msg);
+
+ msg.acknowledge();
+
+ cons.close();
+
+ cons = session.createConsumer("queue3");
+
+ session.start();
+
+ msg = cons.receive(5000);
+
+ assertNotNull(msg);
+
+ msg.acknowledge();
+
+ cons.close();
+
+ session.deleteQueue("queue2");
+ session.deleteQueue("queue3");
+
+ session.close();
+ }
+
+ public void _testQueueWithWildcard3() throws Exception
+ {
+ session.createQueue("a.b", "queue1");
+ session.createTemporaryQueue("a.#", "queue2");
+ session.createTemporaryQueue("a.#", "queue2.1");
+
+ session.deleteQueue("queue2");
+ }
+
/**
* @see
org.hornetq.core.server.impl.ServerSessionImpl#doHandleCreateQueue(org.hornetq.core.remoting.impl.wireformat.CreateQueueMessage)
*/