Issues reading events from RabbitMQ queue on Axon 3.3.5

Imported from Google Groups
1

Using Axon 3.3.5, I am trying to read events from an AMQP queue.

2

Hi Marcos,

On application.properties you should define: axon.eventhandling.processors.team.source=teamQueueMessageSource

and try to use it:

@Configuration
@Slf4j
public class AMQPConfig {

@Bean
public SpringAMQPMessageSource teamQueueMessageSource(Serializer serializer) {
return new SpringAMQPMessageSource(new DefaultAMQPMessageConverter(serializer)) {

@RabbitListener(queues = “team”)
@Override
public void onMessage(Message message, Channel channel) {
log.debug(“Event Received: {}”);

log.debug(“Event Received: {}”, message);
super.onMessage(message, channel);
}
};
}

}