(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.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502627 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 3 deletions

diff --git a/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java b/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
index f61516fc5a..c01987cfc0 100644
--- a/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
+++ b/qpid/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java
@@ -156,7 +156,7 @@ public class PingAsyncTestPerf extends PingTestPerf implements TimingControllerA
 
         // 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 @@ public class PingAsyncTestPerf extends PingTestPerf implements TimingControllerA
 
         // 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 @@ public class PingAsyncTestPerf extends PingTestPerf implements TimingControllerA
         }
 
         // 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);