ProjectionEndpoint

public class ProjectionEndpoint<I, P extends Projection<I, S, ? extends Object>, S extends EntityState> extends EntityMessageEndpoint<I, E, M> implements EventEndpoint<I>

Dispatches an event to projections.

Constructors

protected void afterDispatched(I entityId)

The callback invoked after the message is dispatched to an entity with the given ID.

protected DispatchOutcome invokeDispatcher(P projection)

Invokes entity-specific method for dispatching the message.

protected boolean isModified(P projection)

Verifies whether the entity was modified during the message dispatching.

protected void onEmptyResult(P entity)

Does nothing since a state of a projection should not be necessarily updated upon execution of a subscriber method.

protected void onModified(P projection)

Callback to perform operations if the entity was modified during message dispatching.

protected DispatchOutcome performDispatch(I entityId)

Performs actual dispatching of the signal to the respective target by the passed ID.

Obtains the parent repository of this endpoint.

protected DispatchOutcome runTransactionFor(P projection)

public final DispatchOutcome dispatchTo(I targetId)

Dispatches the message to the target with the passed ID.

protected final M envelope()

Obtains the envelope of the message processed by this endpoint.

public void onDuplicate(I target, EventEnvelope envelope)

public abstract void onDuplicate(I target, M envelope)

The callback invoked if the handled signal is a duplicate.

protected final void store(E entity)

Stores the entity if it was modified during message dispatching.