This closes #1047
This commit is contained in:
commit
f7a9ba4f65
|
@ -253,10 +253,6 @@ public final class ClientConsumerImpl implements ClientConsumerInternal {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (m != null) {
|
|
||||||
session.workDone();
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
wait(toWait);
|
wait(toWait);
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
|
|
Loading…
Reference in New Issue