jeudi 26 mars 2015

How to add an additional Listener to listen to queue with Spring AMQP?

I currently have a FooListener that listens to a queue containing Foo messages. How do I add another BarListener class to listen to the same queue for Bar messages?


My RabbitMQ is currently configured like this:



@Configuration
public class RabbitMQConfig {
@Bean
public MessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueues(workQueue());
container.setMessageListener(new MessageListenerAdapter(fooListener(), new JsonMessageConverter()));
container.setDefaultRequeueRejected(false);
return container;
}
}

Aucun commentaire:

Enregistrer un commentaire