Package org.springframework.modulith.events.support

Class DelegatingEventExternalizer

java.lang.Object

org.springframework.modulith.events.support.EventExternalizationSupport

org.springframework.modulith.events.support.DelegatingEventExternalizer

All Implemented Interfaces:

ConditionalEventListener

@Component
public class DelegatingEventExternalizer
extends EventExternalizationSupport

An EventExternalizationSupport delegating to a BiFunction for the actual externalization. Note, that this needs to be a Component to make sure it is considered an event listener, as without the annotation Spring Framework would skip it as it lives in the org.springframework package.

Since:

1.1

Author:

Oliver Drotbohm

Constructor Summary

Constructors

Constructor	Description
DelegatingEventExternalizer(EventExternalizationConfiguration configuration, BiFunction<RoutingTarget,Object,CompletableFuture<?>> delegate)	Creates a new DelegatingEventExternalizer for the given EventExternalizationConfiguration and BiFunction implementing the actual externalization.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<?>	externalize(Object event)	Externalizes the given event.
protected CompletableFuture<?>	externalize(Object payload, RoutingTarget target)	Publish the given payload to the given RoutingTarget.

Methods inherited from class org.springframework.modulith.events.support.EventExternalizationSupport

supports

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingEventExternalizer

public DelegatingEventExternalizer(EventExternalizationConfiguration configuration,
 BiFunction<RoutingTarget,Object,CompletableFuture<?>> delegate)

Creates a new DelegatingEventExternalizer for the given EventExternalizationConfiguration and BiFunction implementing the actual externalization.

Parameters:

configuration - must not be null.

delegate - must not be null.

Method Details

externalize

@ApplicationModuleListener(propagation=SUPPORTS)
public CompletableFuture<?> externalize(Object event)

Description copied from class: EventExternalizationSupport

Externalizes the given event.

Overrides:

externalize in class EventExternalizationSupport

Parameters:

event - must not be null.

Returns:

the externalization result, will never be null.

externalize

protected CompletableFuture<?> externalize(Object payload,
 RoutingTarget target)

Description copied from class: EventExternalizationSupport

Publish the given payload to the given RoutingTarget.

Specified by:

externalize in class EventExternalizationSupport

Parameters:

payload - must not be null.

target - must not be null.

Returns:

the externalization result, will never be null.