Axon 3.3.5 を使用して、AMQP キューからイベントを読み取ろうとしています。
/**
* AMQP subscribing
*/
@Bean
SpringAMQPMessageSource notificationsEventsQueue(Serializer serializer) {
return new SpringAMQPMessageSource(serializer) {
@Override
@Transactional
@RabbitListener(id = "eventsQueue", queues = "notificationsEventsQueue")
public void onMessage(Message message, Channel channel) {
super.onMessage(message, channel);
}
};
}
@Autowired
public void configure(EventProcessingConfiguration conf, SpringAMQPMessageSource src) {
conf.registerSubscribingEventProcessor("notificationsServiceEventProcessor", c -> src);
}
メソッドをデバッグしたonMessage
ところ、新しいメッセージが届いたとき、eventProcessors
リストは常に空なので、メッセージはアプリケーションによって処理されません。
私は何を見逃していますか?