Package org.axonframework.messaging.eventhandling.gateway

Class DefaultEventGateway

java.lang.Object

org.axonframework.messaging.eventhandling.gateway.DefaultEventGateway

All Implemented Interfaces:

EventGateway

public class DefaultEventGateway
extends Object
implements EventGateway

Default implementation of the EventGateway interface using the EventSink to publish events.

Since:

4.1.0

Author:

Bert laverman, Mitchell Herrijgers

Constructor Summary

Constructors

Constructor	Description
DefaultEventGateway(EventSink eventSink, MessageTypeResolver messageTypeResolver)	Creates a new EventGateway that uses the given eventSink to publish events.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	publish(ProcessingContext context, List<?> events)	Publishes the given events within the given context.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.messaging.eventhandling.gateway.EventGateway

publish, publish

Constructor Details

DefaultEventGateway

public DefaultEventGateway(@Nonnull
 EventSink eventSink,
 @Nonnull
 MessageTypeResolver messageTypeResolver)

Creates a new EventGateway that uses the given eventSink to publish events. The messageTypeResolver is used to resolve the type of the event if no EventMessage is provided but a payload.

Parameters:

eventSink - The EventSink to publish events to.

messageTypeResolver - The MessageTypeResolver to resolve the type of the event.

Method Details

publish

public CompletableFuture<Void> publish(@Nullable
 ProcessingContext context,
 @Nonnull
 List<?> events)

Description copied from interface: EventGateway

Publishes the given events within the given context. When present, the events should be published as part of the context's lifecycle.

The events are mapped to EventMessages before they are given to an EventSink.

Specified by:

publish in interface EventGateway

Parameters:

context - The processing context, if any, to publish the given events in.

events - The collection of events to publish.

Returns:

A CompletableFuture of Void. Completion of the future depends on the EventSink used by this gateway.