Package org.axonframework.disruptor.commandhandling

Class EventPublisher

java.lang.Object
org.axonframework.disruptor.commandhandling.EventPublisher
All Implemented Interfaces:
com.lmax.disruptor.EventHandler<CommandHandlingEntry>
public class EventPublisher extends Object implements com.lmax.disruptor.EventHandler<CommandHandlingEntry>
Component of the DisruptorCommandBus that stores and publishes events generated by the command's execution.
Since:
2.0
Author:
Allard Buijze

  • Constructor Summary

    Constructors
    Constructor
    Description
    EventPublisher(Executor executor, org.axonframework.common.transaction.TransactionManager transactionManager, org.axonframework.messaging.unitofwork.RollbackConfiguration rollbackConfiguration, int segmentId)
    Initializes the EventPublisher to publish Events to the given eventStore and eventBus for aggregate of given aggregateType.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onEvent(CommandHandlingEntry entry, long sequence, boolean endOfBatch)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • EventPublisher

      public EventPublisher(Executor executor, org.axonframework.common.transaction.TransactionManager transactionManager, org.axonframework.messaging.unitofwork.RollbackConfiguration rollbackConfiguration, int segmentId)
      Initializes the EventPublisher to publish Events to the given eventStore and eventBus for aggregate of given aggregateType.
      Parameters:
      executor - The executor which schedules response reporting
      transactionManager - The transaction manager that manages the transaction around event storage and publication
      rollbackConfiguration - The configuration that indicates which exceptions should result in a UnitOfWork
      segmentId - The ID of the segment this publisher should handle

  • Method Details