Package com.opencqrs.framework.command

Class CommandEventCapturer<I>

java.lang.Object

com.opencqrs.framework.persistence.EventCapturer

com.opencqrs.framework.command.CommandEventCapturer<I>

Type Parameters:

I - the instance as defined by the CommandHandlerDefinition being executed

All Implemented Interfaces:

CommandEventPublisher<I>, EventPublisher

public class CommandEventCapturer<I>
extends EventCapturer
implements CommandEventPublisher<I>

Default implementation of CommandEventPublisher used by CommandRouter to apply events to the StateRebuildingHandlers relevant for the Command being executed.

Constructor Summary

Constructors

Constructor	Description
CommandEventCapturer(I initialInstance, String subject, List<StateRebuildingHandlerDefinition<I,Object>> stateRebuildingHandlerDefinitions)

Method Summary

Modifier and Type	Method	Description
<E> I	publish(E event, Map<String,?> metaData)	Publishes an event and its meta-data to the subject specified by Command.getSubject() and applies it to any assignable StateRebuildingHandlers participating in the command execution.
<E> I	publishRelative(String subjectSuffix, E event, Map<String,?> metaData)	Publishes an event and its meta-data to the subject specified by Command.getSubject() appended with the specified suffix and applies it to any assignable StateRebuildingHandlers participating in the command execution.

Methods inherited from class com.opencqrs.framework.persistence.EventCapturer

getEvents, publish

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.opencqrs.framework.command.CommandEventPublisher

publish, publishRelative

Methods inherited from interface com.opencqrs.framework.persistence.EventPublisher

publish, publish, publish

Constructor Details

CommandEventCapturer

public CommandEventCapturer(I initialInstance,
 String subject,
 List<StateRebuildingHandlerDefinition<I,Object>> stateRebuildingHandlerDefinitions)

Method Details

publish

public <E> I publish(E event,
 Map<String,?> metaData)

Description copied from interface: CommandEventPublisher

Publishes an event and its meta-data to the subject specified by Command.getSubject() and applies it to any assignable StateRebuildingHandlers participating in the command execution.

Specified by:

publish in interface CommandEventPublisher<I>

Type Parameters:

E - the event type

Parameters:

event - the event to be published

metaData - the event meta-data to be published

Returns:

an updated or new instance with all events applied

publishRelative

public <E> I publishRelative(String subjectSuffix,
 E event,
 Map<String,?> metaData)

Description copied from interface: CommandEventPublisher

Publishes an event and its meta-data to the subject specified by Command.getSubject() appended with the specified suffix and applies it to any assignable StateRebuildingHandlers participating in the command execution.

Specified by:

publishRelative in interface CommandEventPublisher<I>

Type Parameters:

E - the event type

Parameters:

subjectSuffix - the suffix to be appended to the Command.getSubject() currently executed, must not start with /

event - the event to be published

metaData - the event meta-data to be published

Returns:

an updated or new instance with all events applied