This closes #138

This commit is contained in:
Timothy Bish 2015-08-06 10:00:25 -04:00
commit 99229504d3
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();