org.axonframework.eventhandling

Interface EventBus

All Superinterfaces:

MessageDispatchInterceptorSupport<EventMessage<?>>, SubscribableMessageSource<EventMessage<?>>

All Known Subinterfaces:

EventStore

All Known Implementing Classes:

AbstractEventBus, AbstractEventStore, AxonServerEventStore, EmbeddedEventStore, SimpleEventBus

public interface EventBus
extends SubscribableMessageSource<EventMessage<?>>, MessageDispatchInterceptorSupport<EventMessage<?>>

Specification of the mechanism on which the Event Listeners can subscribe for events and event publishers can publish their events. The event bus dispatches events to all subscribed listeners.

Implementations may or may not dispatch the events to event listeners in the dispatching thread.

Since:

0.1

Author:

Allard Buijze

See Also:

EventMessageHandler, SimpleEventBus

Method Summary

Modifier and Type	Method and Description
default void	publish(EventMessage<?>... events) Publish a collection of events on this bus (one, or multiple).
void	publish(List<? extends EventMessage<?>> events) Publish a collection of events on this bus (one, or multiple).
Registration	registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor) Register the given interceptor with this bus.

Methods inherited from interface org.axonframework.messaging.SubscribableMessageSource

subscribe

Method Detail

publish

default void publish(EventMessage<?>... events)

Publish a collection of events on this bus (one, or multiple). The events will be dispatched to all subscribed listeners.

Implementations may treat the given events as a single batch and distribute the events as such to all subscribed EventListeners.

Parameters:

events - The collection of events to publish

publish

void publish(List<? extends EventMessage<?>> events)

Publish a collection of events on this bus (one, or multiple). The events will be dispatched to all subscribed listeners.

Implementations may treat the given events as a single batch and distribute the events as such to all subscribed EventListeners.

Parameters:

events - The collection of events to publish

registerDispatchInterceptor

Registration registerDispatchInterceptor(MessageDispatchInterceptor<? super EventMessage<?>> dispatchInterceptor)

Register the given interceptor with this bus. When subscribed it will intercept any event messages published on this bus.

If the given interceptor is already registered, nothing happens.

Specified by:

registerDispatchInterceptor in interface MessageDispatchInterceptorSupport<EventMessage<?>>

Parameters:

dispatchInterceptor - The event message dispatch interceptor to register

Returns:

a handle to unregister the dispatchInterceptor. When unregistered it will no longer be given event messages published on this bus.