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();