activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject [1/2] activemq git commit: Added code to sleep for the receive delay to receiveAsyncCountBasedMessages().
Date Thu, 06 Aug 2015 14:00:59 GMT
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 <jakub.korab@gmail.com>
Authored: Fri Jul 31 14:26:31 2015 +0200
Committer: Timothy Bish <tabish121@gmail.com>
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();


Mime
View raw message