mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@464643 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
5159e2b9ad
commit
2e08bc7f37
|
@ -421,7 +421,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
|
|||
checkClosed();
|
||||
checkMessageListener();
|
||||
|
||||
sendPullCommand(-1);
|
||||
sendPullCommand(0);
|
||||
MessageDispatch md = dequeue(-1);
|
||||
if (md == null)
|
||||
return null;
|
||||
|
|
Loading…
Reference in New Issue