From 4cfb8dc6024dba8ce6f5a6bce26bea29a5e79477 Mon Sep 17 00:00:00 2001
From: Jakub Korab <jakub.korab@gmail.com>
Date: Fri, 31 Jul 2015 14:26:31 +0200
Subject: [PATCH] Added code to sleep for the receive delay to
 receiveAsyncCountBasedMessages().

---
 .../main/java/org/apache/activemq/tool/JmsConsumerClient.java   | 2 ++
 1 file changed, 2 insertions(+)

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 d6608832b1..3fc90a5f28 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();