我正在使用MessageListener從指定的隊列中讀取消息，並希望在隊列中獲得消息後執行處理。在消息處理前一個消息處理期間，onMessage（）方法不處理下一消息

Question

這裏是我的代碼

@Bean 
public MessageListenerContainer messageListenerContainer() 
{ 
    SimpleMessageListenerContainer messageListenerContainer = new SimpleMessageListenerContainer(); 
    messageListenerContainer.setConnectionFactory(connectionFactory()); 
    messageListenerContainer.setQueueNames("queue"); 
    messageListenerContainer.setMessageListener(vceListener()); 
    return messageListenerContainer; 
} 

@Bean 
public VListener vceListener() 
{ 
    return new VListener(); 
} 

@Component 
public class VListener implements MessageListener 
{ 
    @Override 
    public void onMessage(Message message) 
    { 
     //start process 
    } 
} 

我的處理時間更是對一個消息，當一個消息的過程是怎麼回事，我不能處理它的隊列來另一條消息。

所以，我斜面處理多個消息並行

Answer 1

添加

messageListenerContainer.setConcurrentConsumers(5); 

（或任何併發性需要）。

請參閱the documentation for other container properties。