From 5e52dd94f3cf0f2b5a47b5a872487b4ba7e25fb4 Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Fri, 2 Feb 2007 15:31:30 +0000 Subject: (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/qpid@502627 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'java/perftests/src/test') diff --git a/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java b/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java index f61516fc5a..c01987cfc0 100644 --- a/java/perftests/src/test/java/org/apache/qpid/ping/PingAsyncTestPerf.java +++ b/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); -- cgit v1.2.1