svn commit: r502627 - /incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java

[rgreig]

Author: rgreig
Date: Fri Feb  2 07:31:30 2007
New Revision: 502627

URL: http://svn.apache.org/viewvc?view=rev&rev=502627
Log:
(Submitted by Rupert Smith)
Fixed problem with losing message results. Was not passing in self generated 
message correlation id in the async test, to match up replies with.

Modified:
    
incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java

Modified: 
incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java?view=diff&rev=502627&r1=502626&r2=502627
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
 Fri Feb  2 07:31:30 2007
@@ -156,7 +156,7 @@
 
         // Attach the chained message listener to the ping producer to listen 
asynchronously for the replies to these
         // messages.
-        pingClient.setChainedMessageListener(batchedResultsListener);
+        //pingClient.setChainedMessageListener(batchedResultsListener);
 
         // Generate a sample message of the specified size.
         ObjectMessage msg =
@@ -166,7 +166,7 @@
 
         // Send the requested number of messages, and wait until they have all 
been received.
         long timeout = 
Long.parseLong(testParameters.getProperty(PingPongProducer.TIMEOUT_PROPNAME));
-        int numReplies = pingClient.pingAndWaitForReply(msg, numPings, 
timeout);
+        int numReplies = pingClient.pingAndWaitForReply(msg, numPings, 
timeout, messageCorrelationId);
 
         // Check that all the replies were received and log a fail if they 
were not.
         if (numReplies < numPings)
@@ -175,7 +175,7 @@
         }
 
         // Remove the chained message listener from the ping producer.
-        pingClient.removeChainedMessageListener();
+        //pingClient.removeChainedMessageListener();
 
         // Remove the expected count and timing controller for the message 
correlation id, to ensure they are cleaned up.
         perCorrelationIds.remove(messageCorrelationId);