Added code to sleep for the receive delay to receiveAsyncCountBasedMessages().

This commit is contained in:
Jakub Korab 2015-07-31 14:26:31 +02:00 committed by Timothy Bish
parent bab04458e4
commit 4cfb8dc602
1 changed files with 2 additions and 0 deletions

View File

@ -173,6 +173,8 @@ public class JmsConsumerClient extends AbstractJmsMeasurableClient {
@Override
public void onMessage(Message msg) {
incThroughput();
sleep();
recvCount.incrementAndGet();
synchronized (recvCount) {
recvCount.notify();