diff options
| author | Keith Wall <kwall@apache.org> | 2012-07-18 16:58:39 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-07-18 16:58:39 +0000 |
| commit | fb4e845bb1b914ebdc2941ad0adcb03fc47d0aeb (patch) | |
| tree | 53ffa33d7378b830bd27040aca15184a17c1495d /qpid/java/perftests/src | |
| parent | e4403022647c3df03a9216a8ab8a6ae7a8d121cd (diff) | |
| download | qpid-python-fb4e845bb1b914ebdc2941ad0adcb03fc47d0aeb.tar.gz | |
QPID-4143: include baseline data in charts.
Applied patch from Philip Harvey <phil@philharveyonline.com>.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1363017 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests/src')
2 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java index 368a25c929..f9d50e8e64 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java @@ -86,6 +86,8 @@ public class ConsumerParticipant implements Participant } else { + LOGGER.info("Consumer {} registering listener", getName()); + _jmsDelegate.registerListener(_command.getParticipantName(), new MessageListener(){ @Override @@ -120,7 +122,7 @@ public class ConsumerParticipant implements Participant private void synchronousRun() { - LOGGER.debug("entered synchronousRun: " + this); + LOGGER.info("Consumer {} about to consume messages", getName()); _startTime = System.currentTimeMillis(); diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java index c02c4faed9..63cbe98b5c 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java @@ -78,6 +78,8 @@ public class ProducerParticipant implements Participant _limiter = ExecutorWithLimitsFactory.createExecutorWithLimit(startTime, requiredDuration); + LOGGER.info("Producer {} about to send messages", getName()); + while (true) { try @@ -162,6 +164,7 @@ public class ProducerParticipant implements Participant long sleepTime = _command.getStartDelay(); if (sleepTime > 0) { + LOGGER.debug("{} sleeping for {} milliseconds before starting", getName(), sleepTime); // start delay is specified. Sleeping... doSleep(sleepTime); } |