io.spine.server.entity

Interface EventProducingRepository

All Known Implementing Classes:

AggregatePartRepository, AggregateRepository, ProcessManagerRepository

public interface EventProducingRepository

Operations common for repositories that can post to EventBus.

Method Summary

Modifier and Type	Method and Description
EventBus	eventBus() Obtains the EventBus to which the repository posts.
EventFilter	eventFilter() Declared for mixing-in with Repository.eventFilter().
default java.lang.Iterable<io.spine.core.Event>	filter(java.util.Collection<io.spine.core.Event> events) Filters passed events using the EventProducingRepository.eventFilter() filter} of this repository.
com.google.common.collect.ImmutableSet<EventClass>	outgoingEvents() Obtains classes of the events produced by entities of this repository.
default void	postEvents(java.util.Collection<io.spine.core.Event> events) Filters the passed events and posts the result to the EventBus.
default void	postIfCommandRejected(SignalEnvelope<?,?,?> signal, java.lang.Throwable cause) If the passed signal is a command and the thrown cause is a rejection, posts the rejection to the associated EventBus.

Method Detail

outgoingEvents

com.google.common.collect.ImmutableSet<EventClass> outgoingEvents()

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

eventBus

EventBus eventBus()

Obtains the EventBus to which the repository posts.

eventFilter

EventFilter eventFilter()

Declared for mixing-in with Repository.eventFilter().

filter

default java.lang.Iterable<io.spine.core.Event> filter(java.util.Collection<io.spine.core.Event> events)

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

postEvents

default void postEvents(java.util.Collection<io.spine.core.Event> events)

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

postIfCommandRejected

default void postIfCommandRejected(SignalEnvelope<?,?,?> signal,
                                   java.lang.Throwable cause)

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