Package org.springframework.modulith.events

Class DefaultEventPublicationRegistry

java.lang.Object

org.springframework.modulith.events.DefaultEventPublicationRegistry

All Implemented Interfaces:

DisposableBean, EventPublicationRegistry

public class DefaultEventPublicationRegistry
extends Object
implements DisposableBean, 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

Constructor Summary

Constructors

Constructor	Description
DefaultEventPublicationRegistry(EventPublicationRepository events)	Creates a new DefaultEventPublicationRegistry for the given EventPublicationRepository.

Method Summary

Modifier and Type	Method	Description
void	destroy()
Iterable<EventPublication>	findIncompletePublications()	Returns all EventPublications that have not been completed yet.
void	markCompleted(Object event, PublicationTargetIdentifier targetIdentifier)	Marks the publication for the given event and PublicationTargetIdentifier as completed.
void	store(Object event, Stream<PublicationTargetIdentifier> listeners)	Stores EventPublications for the given event and ApplicationListeners.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultEventPublicationRegistry

public DefaultEventPublicationRegistry(EventPublicationRepository events)

Creates a new DefaultEventPublicationRegistry for the given EventPublicationRepository.

Parameters:

events - must not be null.

Method Details

store

public void store(Object event,
 Stream<PublicationTargetIdentifier> listeners)

Description copied from interface: EventPublicationRegistry

Stores EventPublications for the given event and ApplicationListeners.

Specified by:

store in interface EventPublicationRegistry

Parameters:

event - must not be null.

listeners - must not be null.

findIncompletePublications

public Iterable<EventPublication> findIncompletePublications()

Description copied from interface: EventPublicationRegistry

Returns all EventPublications that have not been completed yet.

Specified by:

findIncompletePublications in interface EventPublicationRegistry

Returns:

will never be null.

markCompleted

@Transactional(propagation=REQUIRES_NEW)
public void markCompleted(Object event,
 PublicationTargetIdentifier targetIdentifier)

Description copied from interface: EventPublicationRegistry

Marks the publication for the given event and PublicationTargetIdentifier as completed.

Specified by:

markCompleted in interface EventPublicationRegistry

Parameters:

event - must not be null.

targetIdentifier - must not be null.

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean