You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2010/02/25 16:44:51 UTC
svn commit: r916327 - in /qpid/trunk/qpid/java: ./
perftests/src/main/java/org/apache/qpid/ping/PingClient.java
perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java
Author: ritchiem
Date: Thu Feb 25 15:44:51 2010
New Revision: 916327
URL: http://svn.apache.org/viewvc?rev=916327&view=rev
Log:
QPID-2421 : Update to expose the PingClient count so we can set the correlationID correctly for test with > 1 -c[] value.
Modified:
qpid/trunk/qpid/java/ (props changed)
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java
Propchange: qpid/trunk/qpid/java/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Feb 25 15:44:51 2010
@@ -1,5 +1,5 @@
/qpid/branches/0.5.x-dev:886720-886722
-/qpid/branches/0.5.x-dev/qpid/java:886720-886722,887145,892761,894875,916304
+/qpid/branches/0.5.x-dev/qpid/java:886720-886722,887145,892761,894875,916304,916325
/qpid/branches/java-broker-0-10/qpid/java:795950-829653
/qpid/branches/java-network-refactor/qpid/java:805429-821809
/qpid/trunk/qpid:796646-796653
Modified: qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java?rev=916327&r1=916326&r2=916327&view=diff
==============================================================================
--- qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java (original)
+++ qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingClient.java Thu Feb 25 15:44:51 2010
@@ -104,4 +104,9 @@
return _pingClientCount * _noOfConsumers;
}
}
+
+ public int getClientCount()
+ {
+ return _pingClientCount;
+ }
}
Modified: qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java?rev=916327&r1=916326&r2=916327&view=diff
==============================================================================
--- qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java (original)
+++ qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/ping/PingTestPerf.java Thu Feb 25 15:44:51 2010
@@ -148,7 +148,7 @@
{
// Manually set the correlation ID to 1. This is not ideal but it is the
// value that the main test loop will use.
- perThreadSetup._pingClient.pingNoWaitForReply(null, preFill, "1");
+ perThreadSetup._pingClient.pingNoWaitForReply(null, preFill, String.valueOf(perThreadSetup._pingClient.getClientCount()));
// Note with a large preFill and non-tx session the messages will be
// rapidly pushed in to the mina buffers. OOM's are a real risk here.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org