[jbossws-commits] JBossWS SVN: r2366 - branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport.

[jbossws-commits at lists.jboss.org]

Author: thomas.diesler at jboss.com
Date: 2007-02-15 08:36:51 -0500 (Thu, 15 Feb 2007)
New Revision: 2366

Modified:
   branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport/JMSTransportTestCase.java
Log:
Improve response waiting

Modified: branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport/JMSTransportTestCase.java
===================================================================
--- branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport/JMSTransportTestCase.java	2007-02-15 09:26:25 UTC (rev 2365)
+++ branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport/JMSTransportTestCase.java	2007-02-15 13:36:51 UTC (rev 2366)
@@ -34,6 +34,8 @@
  */
 public class JMSTransportTestCase extends JBossWSTest
 {
+   private static boolean waitForResponse;
+   
    public static Test suite() throws Exception
    {
       return JBossWSTestSetup.newTestSetup(JMSTransportTestCase.class, "jaxrpc-samples-jmstransport.sar");
@@ -84,11 +86,18 @@
       TextMessage message = session.createTextMessage(reqMessage);
       message.setJMSReplyTo(resQueue);
 
+      waitForResponse = true;
+      
       QueueSender sender = session.createSender(reqQueue);
       sender.send(message);
       sender.close();
 
-      Thread.sleep(500);
+      int timeout = 5000;
+      while (waitForResponse && timeout > 0)
+      {
+         Thread.sleep(100);
+         timeout -= 100;
+      }
 
       assertNotNull("Expected response message", responseListener.resMessage);
       assertEquals(DOMUtils.parse(resMessage), DOMUtils.parse(responseListener.resMessage));
@@ -108,6 +117,7 @@
          try
          {
             resMessage = textMessage.getText();
+            waitForResponse = false;
          }
          catch (Throwable t)
          {