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