svn commit: r584099 - in /incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall: Client.java Service.java

[arnaudsimon]

Author: arnaudsimon
Date: Fri Oct 12 01:41:02 2007
New Revision: 584099

URL: http://svn.apache.org/viewvc?rev=584099&view=rev
Log:
Changed the way temporary queues are created

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Client.java
    
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Service.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Client.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Client.java?rev=584099&r1=584098&r2=584099&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Client.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Client.java
 Fri Oct 12 01:41:02 2007
@@ -31,6 +31,7 @@
 
 import javax.jms.Message;
 import javax.jms.MessageListener;
+import javax.jms.MessageProducer;
 
 /**
  * Declare a private temporary response queue,
@@ -66,10 +67,12 @@
             new AMQQueue(_connection.getDefaultQueueExchangeName(), new 
AMQShortString("ResponseQueue"), true);
         _session.createConsumer(response).setMessageListener(this);
         _connection.start();
-        AMQQueue service = new SpecialQueue(_connection, "ServiceQueue");
+      //  AMQQueue service = new SpecialQueue(_connection, "ServiceQueue");
+        AMQQueue service  = (AMQQueue)  _session.createQueue("ServiceQueue") ;
         Message request = _session.createTextMessage("Request!");
         request.setJMSReplyTo(response);
-        _session.createProducer(service).send(request);
+        MessageProducer prod = _session.createProducer(service);
+        prod.send(request);
     }
 
     void shutdownWhenComplete() throws Exception
@@ -95,7 +98,7 @@
 
         if (_count < _expected)
         {
-            wait(10000L);
+            wait(1000000000);
         }
 
         if (_count < _expected)

Modified: 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Service.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Service.java?rev=584099&r1=584098&r2=584099&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Service.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/forwardall/Service.java
 Fri Oct 12 01:41:02 2007
@@ -54,8 +54,9 @@
     Service(AMQConnection connection) throws Exception
     {
         _connection = connection;
-        AMQQueue queue = new SpecialQueue(connection, "ServiceQueue");
+        //AMQQueue queue = new SpecialQueue(connection, "ServiceQueue");
         _session = (AMQSession) _connection.createSession(false, 
AMQSession.NO_ACKNOWLEDGE);
+          AMQQueue queue  = (AMQQueue)  _session.createQueue("ServiceQueue") ;
         _session.createConsumer(queue).setMessageListener(this);
         _connection.start();
     }