Hi,
My config:
@Bean
public EventBus eventBus() {
ClusteringEventBus ret = new ClusteringEventBus(new DefaultClusterSelector(localCluster()));
return ret;
}
@Bean
public Cluster localCluster() {
return new SimpleCluster(“local”);
}
@Bean
public ReplayingCluster replayingCluster() throws SQLException {
ReplayingCluster ret = new ReplayingCluster(localCluster(), eventStore(), new SpringTransactionManager(axonTransactionManager()), 100, new BackloggingIncomingMessageHandler());
return ret;
}
@Bean
public AnnotationEventListenerBeanPostProcessor annotationEventListenerBeanPostProcessor() {
AnnotationEventListenerBeanPostProcessor postProcessor = new AnnotationEventListenerBeanPostProcessor();
postProcessor.setEventBus(eventBus());
return postProcessor;
}
Then I have an EventListener implements ReplayAware with @EventListener annotations
Event handling works, replay works but the BeforeReplay is never called.
Am I missing something?
Geir