org.axonframework.eventhandling

Class SimpleEventBus

java.lang.Object

org.axonframework.eventhandling.AbstractEventBus

org.axonframework.eventhandling.SimpleEventBus

All Implemented Interfaces:

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

public class SimpleEventBus
extends AbstractEventBus

Implementation of the EventBus that dispatches events in the thread the publishes them.

Since:

0.5

Author:

Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleEventBus.Builder Builder class to instantiate a SimpleEventBus.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static SimpleEventBus.Builder	builder() Instantiate a Builder to be able to create a SimpleEventBus.

Methods inherited from class org.axonframework.eventhandling.AbstractEventBus

afterCommit, commit, intercept, prepareCommit, publish, queuedMessages, registerDispatchInterceptor, subscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.eventhandling.EventBus

publish

Constructor Detail

SimpleEventBus

protected SimpleEventBus(SimpleEventBus.Builder builder)

Instantiate a SimpleEventBus based on the fields contained in the SimpleEventBus.Builder.

Parameters:

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

Method Detail

builder

public static SimpleEventBus.Builder builder()

Instantiate a Builder to be able to create a SimpleEventBus.

The MessageMonitor is defaulted to a NoOpMessageMonitor and the queueCapacity to Integer.MAX_VALUE.

Returns:

a Builder to be able to create a SimpleEventBus