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

public class PersistentApplicationEventMulticaster
extends AbstractApplicationEventMulticaster
implements 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

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)

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

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

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton