EventProducingRepository

Operations common for repositories that can post to EventBus.

Functions

public abstract EventBus eventBus()

Obtains the EventBus to which the repository posts.

Declared for mixing-in with eventFilter.

public Iterable<Event> filter(Collection<Event> events)

Filters passed events using the eventFilter filter} of this repository.

public abstract ImmutableSet<EventClass> outgoingEvents()

Obtains classes of the events produced by entities of this repository.

public void postEvents(Collection<Event> events)

Filters the passed events and posts the result to the EventBus.

public void postIfCommandRejected(SignalEnvelope<? extends Object, ? extends Object, ? extends Object> signal, Throwable cause)

If the passed signal is a command and the thrown cause is a rejection, posts the rejection to the associated EventBus.