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 | 34fb667cc8fc798f83866315623dbbc03ebf8a74 (patch) | |
| tree | 81986399834745aee87e3e4def2edabd7bf6589a /java/perftests/src | |
| parent | 154e323084822584f754fd9b187ef9c6411891ea (diff) | |
| download | qpid-python-34fb667cc8fc798f83866315623dbbc03ebf8a74.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/qpid@1363017 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests/src')
| -rw-r--r-- | java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java | 4 | ||||
| -rw-r--r-- | java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java | 3 |
2 files changed, 6 insertions, 1 deletions
diff --git a/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java b/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java index 368a25c929..f9d50e8e64 100644 --- a/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java +++ b/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/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java b/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java index c02c4faed9..63cbe98b5c 100644 --- a/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java +++ b/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); } |
