[hornetq-commits] JBoss hornetq SVN: r9548 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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) 
     */