org.axonframework.eventhandling.gateway

Class AbstractEventGateway

java.lang.Object

org.axonframework.eventhandling.gateway.AbstractEventGateway

Direct Known Subclasses:

DefaultEventGateway

public abstract class AbstractEventGateway
extends Object

Abstract implementation of an EventGateway, which handles the dispatch interceptors. The actual publishing of events is left to the subclasses.

Since:

4.1

Author:

Bert Laverman

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractEventGateway.Builder Abstract Builder class to instantiate AbstractEventGateway implementations.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventGateway(AbstractEventGateway.Builder builder) Instantiate an AbstractEventGateway based on the fields contained in the AbstractEventGateway.Builder.

Method Summary

Modifier and Type	Method and Description
EventBus	getEventBus() Returns the EventBus used by this EventGateway.
protected <E> EventMessage<? extends E>	processInterceptors(EventMessage<E> eventMessage) Invokes all the dispatch interceptors and returns the EventMessage instance that should be dispatched.
protected void	publish(Object event) Publishes (dispatches) an event.
Registration	registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> interceptor) Registers an event dispatch interceptor within an EventGateway.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractEventGateway

protected AbstractEventGateway(AbstractEventGateway.Builder builder)

Instantiate an AbstractEventGateway based on the fields contained in the AbstractEventGateway.Builder.

Will assert that the EventBus is not null and throws an AxonConfigurationException if it is.

Parameters:

builder - the AbstractEventGateway.Builder used to instantiate a AbstractEventGateway instance

Method Detail

publish

protected void publish(@Nonnull
                       Object event)

Publishes (dispatches) an event.

Parameters:

event - The event to publish.

registerDispatchInterceptor

public Registration registerDispatchInterceptor(@Nonnull
                                                MessageDispatchInterceptor<? super EventMessage<?>> interceptor)

Registers an event dispatch interceptor within an EventGateway.

Parameters:

interceptor - To intercept event messages

Returns:

a registration which can be used to cancel the registration of given interceptor

processInterceptors

protected <E> EventMessage<? extends E> processInterceptors(EventMessage<E> eventMessage)

Invokes all the dispatch interceptors and returns the EventMessage instance that should be dispatched.

Parameters:

eventMessage - The incoming event message

Returns:

The event message to dispatch

getEventBus

public EventBus getEventBus()

Returns the EventBus used by this EventGateway. Should be used for monitoring or testing.

Returns:

the EventBus used by this gateway.