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, TransactionManager transactionManager, 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,
 TransactionManager transactionManager,
 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

onEvent

public void onEvent(CommandHandlingEntry entry,
 long sequence,
 boolean endOfBatch)

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<CommandHandlingEntry>