Package org.springframework.modulith.events.support

Class PersistentApplicationEventMulticaster

java.lang.Object

org.springframework.context.event.AbstractApplicationEventMulticaster

org.springframework.modulith.events.support.PersistentApplicationEventMulticaster

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, SmartInitializingSingleton, ApplicationEventMulticaster, IncompleteEventPublications

public class PersistentApplicationEventMulticaster
extends AbstractApplicationEventMulticaster
implements IncompleteEventPublications, SmartInitializingSingleton

An ApplicationEventMulticaster to register EventPublications in an EventPublicationRegistry so that potentially failing transactional event listeners can get re-invoked upon application restart or via a schedule.

Republication is handled in afterSingletonsInstantiated() inspecting the EventPublicationRegistry for incomplete publications and

Author:

Oliver Drotbohm

See Also:

• CompletionRegisteringAdvisor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	PersistentApplicationEventMulticaster.TransactionalEventListeners	First-class collection to work with transactional event listeners, i.e.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	REPUBLISH_ON_RESTART
(package private) static final String	REPUBLISH_ON_RESTART_LEGACY

Constructor Summary

Constructors

Constructor	Description
PersistentApplicationEventMulticaster(Supplier<EventPublicationRegistry> registry, Supplier<Environment> environment)	Creates a new PersistentApplicationEventMulticaster for the given EventPublicationRegistry.

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
protected Collection<ApplicationListener<?>>	getApplicationListeners(ApplicationEvent event, ResolvableType eventType)
void	multicastEvent(ApplicationEvent event)
void	multicastEvent(ApplicationEvent event, ResolvableType eventType)
void	resubmitIncompletePublications(Predicate<EventPublication> filter)	Triggers the re-submission of events for which incomplete EventPublications are registered.
void	resubmitIncompletePublicationsOlderThan(Duration duration)	Triggers the re-submission of events for which incomplete EventPublications are registered that exceed a certain age regarding their original publication date.

Methods inherited from class org.springframework.context.event.AbstractApplicationEventMulticaster

addApplicationListener, addApplicationListenerBean, getApplicationListeners, removeAllListeners, removeApplicationListener, removeApplicationListenerBean, removeApplicationListenerBeans, removeApplicationListeners, setBeanClassLoader, setBeanFactory, supportsEvent, supportsEvent

Methods inherited from class java.lang.Object

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

Field Details

REPUBLISH_ON_RESTART

static final String REPUBLISH_ON_RESTART

See Also:

• Constant Field Values

REPUBLISH_ON_RESTART_LEGACY

static final String REPUBLISH_ON_RESTART_LEGACY

See Also:

• Constant Field Values

Constructor Details

PersistentApplicationEventMulticaster

public PersistentApplicationEventMulticaster(Supplier<EventPublicationRegistry> registry,
 Supplier<Environment> environment)

Creates a new PersistentApplicationEventMulticaster for the given EventPublicationRegistry.

Parameters:

registry - must not be null.

environment - must not be null.

Method Details

multicastEvent

public void multicastEvent(ApplicationEvent event)

Specified by:

multicastEvent in interface ApplicationEventMulticaster

multicastEvent

public void multicastEvent(ApplicationEvent event,
 @Nullable
 ResolvableType eventType)

Specified by:

multicastEvent in interface ApplicationEventMulticaster

getApplicationListeners

protected Collection<ApplicationListener<?>> getApplicationListeners(ApplicationEvent event,
 ResolvableType eventType)

Overrides:

getApplicationListeners in class AbstractApplicationEventMulticaster

resubmitIncompletePublications

public void resubmitIncompletePublications(Predicate<EventPublication> filter)

Description copied from interface: IncompleteEventPublications

Triggers the re-submission of events for which incomplete EventPublications are registered. Note, that this will materialize all incomplete event publications.

Specified by:

resubmitIncompletePublications in interface IncompleteEventPublications

Parameters:

filter - a Predicate to select the event publications for which to resubmit events.

resubmitIncompletePublicationsOlderThan

public void resubmitIncompletePublicationsOlderThan(Duration duration)

Description copied from interface: IncompleteEventPublications

Triggers the re-submission of events for which incomplete EventPublications are registered that exceed a certain age regarding their original publication date.

Specified by:

resubmitIncompletePublicationsOlderThan in interface IncompleteEventPublications

Parameters:

duration - must not be null.

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton