Repository: activemq Updated Branches: refs/heads/master bab04458e -> 99229504d
Added code to sleep for the receive delay to receiveAsyncCountBasedMessages(). Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/4cfb8dc6 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/4cfb8dc6 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/4cfb8dc6 Branch: refs/heads/master Commit: 4cfb8dc6024dba8ce6f5a6bce26bea29a5e79477 Parents: bab0445 Author: Jakub Korab <[email protected]> Authored: Fri Jul 31 14:26:31 2015 +0200 Committer: Timothy Bish <[email protected]> Committed: Thu Aug 6 09:59:37 2015 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/tool/JmsConsumerClient.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/4cfb8dc6/activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/JmsConsumerClient.java ---------------------------------------------------------------------- diff --git a/activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/JmsConsumerClient.java b/activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/JmsConsumerClient.java index d660883..3fc90a5 100644 --- a/activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/JmsConsumerClient.java +++ b/activemq-tooling/activemq-perf-maven-plugin/src/main/java/org/apache/activemq/tool/JmsConsumerClient.java @@ -173,6 +173,8 @@ public class JmsConsumerClient extends AbstractJmsMeasurableClient { @Override public void onMessage(Message msg) { incThroughput(); + sleep(); + recvCount.incrementAndGet(); synchronized (recvCount) { recvCount.notify();
