diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2008-07-07 20:30:40 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2008-07-07 20:30:40 +0000 |
| commit | 6e92b10d74de7c8acd9803e6488c13673ceadd40 (patch) | |
| tree | 3fb434dc25fffddd764a671da3c238c17767b6db /qpid/java/testkit/src | |
| parent | 0ed50d22182873d604a6208c753a464605d514b8 (diff) | |
| download | qpid-python-6e92b10d74de7c8acd9803e6488c13673ceadd40.tar.gz | |
This is related to QPID-1162
Added a README file to describe what the tests are and how they can be run.
Modified to consumers to print the iteration number instead of the message id.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@674622 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/testkit/src')
| -rw-r--r-- | qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/MultiThreadedConsumer.java | 4 | ||||
| -rw-r--r-- | qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/SimpleConsumer.java | 4 |
2 files changed, 6 insertions, 2 deletions
diff --git a/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/MultiThreadedConsumer.java b/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/MultiThreadedConsumer.java index a44760be46..a91d9e7e85 100644 --- a/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/MultiThreadedConsumer.java +++ b/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/MultiThreadedConsumer.java @@ -80,6 +80,7 @@ public class MultiThreadedConsumer extends BaseTest private boolean startIteration = true; private long startTime = 0; + private long iterations = 0; public void onMessage(Message m) { @@ -98,9 +99,10 @@ public class MultiThreadedConsumer extends BaseTest long totalIterationTime = now - startTime; double throughput = ((double)msg_count/(double)totalIterationTime) * 1000; long latencySample = now - m.getJMSTimestamp(); + iterations++; StringBuilder sb = new StringBuilder(); - sb.append(m.getJMSMessageID()).append(","). + sb.append(iterations).append(","). append(nf.format(throughput)).append(",").append(latencySample); System.out.println(sb.toString()); diff --git a/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/SimpleConsumer.java b/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/SimpleConsumer.java index d353e44816..b3eb97dafe 100644 --- a/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/SimpleConsumer.java +++ b/qpid/java/testkit/src/main/java/org/apache/qpid/testkit/soak/SimpleConsumer.java @@ -74,6 +74,7 @@ public class SimpleConsumer extends BaseTest private boolean startIteration = true; private long startTime = 0; + private long iterations = 0; public void onMessage(Message m) { @@ -93,9 +94,10 @@ public class SimpleConsumer extends BaseTest startIteration = true; double throughput = ((double)msg_count/(double)totalIterationTime) * 1000; long latencySample = now - m.getJMSTimestamp(); + iterations++; StringBuilder sb = new StringBuilder(); - sb.append(m.getJMSMessageID()).append(","). + sb.append(iterations).append(","). append(nf.format(throughput)).append(",").append(latencySample); System.out.println(sb.toString()); |