Interface EventPublicationRegistry
- All Known Implementing Classes:
DefaultEventPublicationRegistry
public interface EventPublicationRegistry
A registry to capture event publications to
ApplicationListener
s. 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 allEventPublication
s that have not been completed yet.void
markCompleted
(Object event, PublicationTargetIdentifier targetIdentifier) Marks the publication for the given event andPublicationTargetIdentifier
as completed.void
store
(Object event, Stream<PublicationTargetIdentifier> listeners) StoresEventPublication
s for the given event andApplicationListener
s.
-
Method Details
-
store
StoresEventPublication
s for the given event andApplicationListener
s.- Parameters:
event
- must not be null.listeners
- must not be null.
-
findIncompletePublications
Collection<EventPublication> findIncompletePublications()Returns allEventPublication
s that have not been completed yet.- Returns:
- will never be null.
-
markCompleted
Marks the publication for the given event andPublicationTargetIdentifier
as completed.- Parameters:
event
- must not be null.targetIdentifier
- must not be null.
-