Interface EventPublicationRegistry
- All Known Implementing Classes:
DefaultEventPublicationRegistry
public interface EventPublicationRegistry
A registry to capture event publications to
ApplicationListeners. Allows to register those publications, mark
them as completed and lookup incomplete publications.- Author:
- Oliver Drotbohm, Björn Kieling, Dmitry Belyaev
-
Method Summary
Modifier and TypeMethodDescriptionReturns allEventPublications that have not been completed yet.voidmarkCompleted(Object event, PublicationTargetIdentifier targetIdentifier) Marks the publication for the given event andPublicationTargetIdentifieras completed.voidstore(Object event, Stream<PublicationTargetIdentifier> listeners) StoresEventPublications for the given event andApplicationListeners.
-
Method Details
-
store
StoresEventPublications for the given event andApplicationListeners.- Parameters:
event- must not be null.listeners- must not be null.
-
findIncompletePublications
Iterable<EventPublication> findIncompletePublications()Returns allEventPublications that have not been completed yet.- Returns:
- will never be null.
-
markCompleted
Marks the publication for the given event andPublicationTargetIdentifieras completed.- Parameters:
event- must not be null.targetIdentifier- must not be null.
-