Я использую MessageListener для чтения сообщений из указанной очереди и хочу выполнить обработку, как только я получу сообщение в очереди.
Вот мой код
@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
}
}
Мое время обработки больше для одного сообщения, и когда выполняется одно сообщение, я не могу обработать другое сообщение, которое поступает в очередь.
Итак, я не могу обрабатывать несколько сообщений параллельно