Package org.springframework.modulith.events.support

Class PersistentApplicationEventMulticaster.TransactionalEventListeners

java.lang.Object

org.springframework.modulith.events.support.PersistentApplicationEventMulticaster.TransactionalEventListeners

Enclosing class:

PersistentApplicationEventMulticaster

static class PersistentApplicationEventMulticaster.TransactionalEventListeners
extends Object

First-class collection to work with transactional event listeners, i.e. ApplicationListener instances that implement TransactionalApplicationListener.

Author:

Oliver Drotbohm

See Also:

• TransactionalEventListener
• TransactionalApplicationListener

Constructor Summary

Constructors

Constructor	Description
TransactionalEventListeners(Collection<ApplicationListener<?>> listeners)	Creates a new PersistentApplicationEventMulticaster.TransactionalEventListeners instance by filtering all elements implementing TransactionalApplicationListener.

Method Summary

Modifier and Type	Method	Description
void	doWithListener(String identifier, Consumer<TransactionalApplicationListener<ApplicationEvent>> callback)	Invokes the given Consumer for the listener with the given identifier.
void	forEach(Consumer<TransactionalApplicationListener<?>> callback)	Invokes the given Consumer for all transactional event listeners.
PersistentApplicationEventMulticaster.TransactionalEventListeners	forPhase(TransactionPhase phase)	Returns all PersistentApplicationEventMulticaster.TransactionalEventListeners for the given TransactionPhase.
void	ifPresent(Consumer<Stream<TransactionalApplicationListener<ApplicationEvent>>> metadata)	Executes the given consumer only if there are actual listeners available.
Stream<TransactionalApplicationListener<ApplicationEvent>>	stream()	Returns all transactional event listeners.

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionalEventListeners

public TransactionalEventListeners(Collection<ApplicationListener<?>> listeners)

Creates a new PersistentApplicationEventMulticaster.TransactionalEventListeners instance by filtering all elements implementing TransactionalApplicationListener.

Parameters:

listeners - must not be null.

Method Details

forPhase

public PersistentApplicationEventMulticaster.TransactionalEventListeners forPhase(TransactionPhase phase)

Returns all PersistentApplicationEventMulticaster.TransactionalEventListeners for the given TransactionPhase.

Parameters:

phase - must not be null.

Returns:

will never be null.

forEach

public void forEach(Consumer<TransactionalApplicationListener<?>> callback)

Invokes the given Consumer for all transactional event listeners.

Parameters:

callback - must not be null.

ifPresent

public void ifPresent(Consumer<Stream<TransactionalApplicationListener<ApplicationEvent>>> metadata)

Executes the given consumer only if there are actual listeners available.

Parameters:

metadata - must not be null.

stream

public Stream<TransactionalApplicationListener<ApplicationEvent>> stream()

Returns all transactional event listeners.

Returns:

will never be null.

doWithListener

public void doWithListener(String identifier,
 Consumer<TransactionalApplicationListener<ApplicationEvent>> callback)

Invokes the given Consumer for the listener with the given identifier.

Parameters:

identifier - must not be null or empty.

callback - must not be null.