[jbossws-commits] JBossWS SVN: r2366 - branches/jbossws-1.2.0/jbossws-tests/src/main/java/org/jboss/test/ws/jaxrpc/samples/jmstransport.
Author: thomas.diesler(a)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)
{