0

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リストは常に空なので、メッセージはアプリケーションによって処理されません。

私は何を見逃していますか?

4

1 に答える 1