Gestionnaires d'événements dans une classe distincte Axon 3.0.3

Question

J'ai une configuration CQRS assez simple ici en utilisant Axon & Spring.

Ceci est la classe de configuration.

@AnnotationDriven 
@Configuration 
public class AxonConfig { 

    @Bean 
    public EventStore eventStore() { 
     ... 
    } 

    @Bean 
    public CommandBus commandBus() { 
     return new SimpleCommandBus(); 
    } 

    @Bean 
    public EventBus eventBus() { 
     return new SimpleEventBus(); 
    } 
} 

Ceci est mon agrégat ...

@Aggregate 
public class ThingAggregate { 
    @AggregateIdentifier 
    private String id; 

    public ThingAggregate() { 
    } 

    public ThingAggregate(String id) { 
     this.id = id; 
    } 

    @CommandHandler 
    public handle(CreateThingCommand cmd) { 
     apply(new ThingCreatedEvent('1234', cmd.getThing())); 
    } 

    @EventSourcingHandler 
    public void on(ThingCreatedEvent event) { 
     // this is called! 
    } 
} 

Ceci est mon EventHandler dans un fichier séparé .java ...

@Component 
public class ThingEventHandler { 

    private ThingRepository repository; 

    @Autowired 
    public ThingEventHandler(ThingRepository thingRepository) { 
     this.repository = conditionRepository; 
    } 

    @EventHandler 
    public void handleThingCreatedEvent(ThingCreatedEvent event) { 
     // this is only called if I publish directly to the EventBus 
     // apply within the Aggregate does not call it! 
     repository.save(event.getThing()); 
    } 
} 

J'utilise le CommandGateway pour envoyer le commande de création originale. Mon CommandHandler dans l'agrégat reçoit la commande bien, mais quand j'appelle apply dans mon agrégat, passant un nouvel événement, mon EventHandler dans la classe externe, n'est pas appelé. Seuls les EventHandlers directement à l'intérieur de la classe Aggregate sont appelés.

Si j'essaie de publier un événement directement dans EventBus, mon EventHandler externe est appelé.

Aucune idée de pourquoi mon EventHandler dans une classe Java externe n'est pas appelé lorsque j'appelle apply dans l'agrégat?

Answer 1

Dans Axon 3, le magasin d'événements est un remplacement pour le bus d'événements. Il s'agit essentiellement d'une implémentation spécialisée qui transmet non seulement des événements à des abonnés, mais les stocke également. Dans votre configuration, vous disposez à la fois d'un bus d'événements et d'un magasin d'événements. Les événements de l'agrégat sont probablement publiés dans le magasin d'événements. Étant donné que vous recevez des événements dans votre gestionnaire lors de la publication directe dans le bus d'événements, vos gestionnaires s'y abonnent. La solution: supprimez le bus d'événement de votre configuration et utilisez exclusivement le magasin d'événements.