2012-10-26 41 views

回答

1

只需調用consumer.receiveNoWait();在一個循環內:

Message message = null; 
while((message = consumer.receiveNoWait()) != null); 

這將消耗與選擇器匹配的所有可用消息。