Uses of Interface
org.axonframework.eventhandling.EventBus

Packages that use EventBus

Package	Description
org.axonframework.boot.autoconfig
org.axonframework.commandhandling.model
org.axonframework.commandhandling.model.inspection
org.axonframework.config
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.scheduling.java
org.axonframework.eventhandling.scheduling.quartz
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.spring.config
org.axonframework.spring.eventhandling.scheduling.java
org.axonframework.spring.eventhandling.scheduling.quartz
org.axonframework.spring.messaging	Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.
org.axonframework.test.aggregate
org.axonframework.test.saga

Uses of EventBus in org.axonframework.boot.autoconfig

Methods in org.axonframework.boot.autoconfig with parameters of type EventBus

Modifier and Type	Method and Description
SpringAMQPPublisher	AMQPAutoConfiguration.amqpBridge(EventBus eventBus, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AMQPMessageConverter amqpMessageConverter)
KafkaPublisher<String,byte[]>	KafkaAutoConfiguration.kafkaPublisher(ProducerFactory<String,byte[]> producerFactory, EventBus eventBus, KafkaMessageConverter<String,byte[]> messageConverter, AxonConfiguration configuration)

Uses of EventBus in org.axonframework.commandhandling.model

Constructors in org.axonframework.commandhandling.model with parameters of type EventBus

Constructor and Description
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus) Initialize a repository for storing aggregates whose structure is defined by given aggregateModel.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus, LockFactory lockFactory) Initialize a repository for storing aggregates described by the given aggregateModel with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus, LockFactory lockFactory, Function<String,?> identifierConverter) Initialize a repository for storing aggregates described by the given AggregateModel, with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize a repository for storing aggregates whose structure is defined by given aggregateModel.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory) Initialize a repository for storing aggregates described by the given aggregateModel with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory, Function<String,?> identifierConverter) Initialize a repository for storing aggregates described by the given AggregateModel, with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus) Initialize a repository for storing aggregates of the given aggregateType.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, LockFactory lockFactory) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, LockFactory lockFactory, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, LockFactory lockFactory, ParameterResolverFactory parameterResolverFactory) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, LockFactory lockFactory, ParameterResolverFactory parameterResolverFactory, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, ParameterResolverFactory parameterResolverFactory) Initialize a repository for storing aggregates of the given aggregateType.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize a repository for storing aggregates of the given aggregateType.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory, ParameterResolverFactory parameterResolverFactory, HandlerDefinition handlerDefinition) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, LockFactory lockFactory, ParameterResolverFactory parameterResolverFactory, HandlerDefinition handlerDefinition, Function<String,?> identifierConverter) Initialize a repository for storing aggregates of the given aggregateType with an additional LockFactory and allowing for a custom identifierConverter to convert a String based identifier to an Identifier Object.
GenericJpaRepository(EntityManagerProvider entityManagerProvider, Class<T> aggregateType, EventBus eventBus, RepositoryProvider repositoryProvider, ParameterResolverFactory parameterResolverFactory, HandlerDefinition handlerDefinition) Initialize a repository for storing aggregates of the given aggregateType.

Uses of EventBus in org.axonframework.commandhandling.model.inspection

Methods in org.axonframework.commandhandling.model.inspection with parameters of type EventBus

Modifier and Type	Method and Description
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> aggregateModel, EventBus eventBus) Initialize an aggregate created by the given aggregateFactory which is described in the given aggregateModel.
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> aggregateModel, EventBus eventBus, boolean generateSequences) Initialize an aggregate created by the given aggregateFactory which is described in the given aggregateModel.
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize an aggregate created by the given aggregateFactory which is described in the given aggregateModel.
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider, boolean generateSequences) Initialize an aggregate created by the given aggregateFactory which is described in the given aggregateModel.
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(T aggregateRoot, AggregateModel<T> aggregateModel, EventBus eventBus) Initialize an aggregate with the given aggregateRoot which is described in the given aggregateModel.
static <T> AnnotatedAggregate<T>	AnnotatedAggregate.initialize(T aggregateRoot, AggregateModel<T> aggregateModel, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize an aggregate with the given aggregateRoot which is described in the given aggregateModel.

Constructors in org.axonframework.commandhandling.model.inspection with parameters of type EventBus

Constructor and Description
AnnotatedAggregate(AggregateModel<T> inspector, EventBus eventBus) Initialize an Aggregate instance for the given aggregateRoot, described by the given aggregateModel that will publish events to the given eventBus.
AnnotatedAggregate(AggregateModel<T> inspector, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize an Aggregate instance for the given aggregateRoot, described by the given aggregateModel that will publish events to the given eventBus.
AnnotatedAggregate(T aggregateRoot, AggregateModel<T> model, EventBus eventBus) Initialize an Aggregate instance for the given aggregateRoot, described by the given aggregateModel that will publish events to the given eventBus.
AnnotatedAggregate(T aggregateRoot, AggregateModel<T> model, EventBus eventBus, RepositoryProvider repositoryProvider) Initialize an Aggregate instance for the given aggregateRoot, described by the given aggregateModel that will publish events to the given eventBus.

Uses of EventBus in org.axonframework.config

Methods in org.axonframework.config that return EventBus

Modifier and Type	Method and Description
protected EventBus	DefaultConfigurer.defaultEventBus(Configuration config) Provides the default EventBus implementation.
default EventBus	Configuration.eventBus() Retrieves the Event Bus defined in this Configuration.

Method parameters in org.axonframework.config with type arguments of type EventBus

Modifier and Type	Method and Description
default Configurer	Configurer.configureEventBus(Function<Configuration,EventBus> eventBusBuilder) Configures the given Event Bus to use in this configuration.

Uses of EventBus in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement EventBus

Modifier and Type	Class and Description
class	AbstractEventBus Base class for the Event Bus.
class	SimpleEventBus Implementation of the EventBus that supports streaming of events via SimpleEventBus.openStream(TrackingToken) but only of the most recently published events as it is not backed by a cache or event storage.

Uses of EventBus in org.axonframework.eventhandling.scheduling.java

Constructors in org.axonframework.eventhandling.scheduling.java with parameters of type EventBus

Constructor and Description
SimpleEventScheduler(ScheduledExecutorService executorService, EventBus eventBus) Initialize the SimpleEventScheduler using the given executorService as trigger and execution mechanism, and publishes events to the given eventBus.
SimpleEventScheduler(ScheduledExecutorService executorService, EventBus eventBus, TransactionManager transactionManager) Initialize the SimpleEventScheduler using the given executorService as trigger and execution mechanism, and publishes events to the given eventBus.

Uses of EventBus in org.axonframework.eventhandling.scheduling.quartz

Methods in org.axonframework.eventhandling.scheduling.quartz with parameters of type EventBus

Modifier and Type	Method and Description
void	QuartzEventScheduler.setEventBus(EventBus eventBus) Sets the event bus to which scheduled events need to be published.

Uses of EventBus in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing with parameters of type EventBus

Modifier and Type	Method and Description
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> inspector, EventBus eventBus, RepositoryProvider repositoryProvider, SnapshotTrigger snapshotTrigger) Initializes an EventSourcedAggregate instance using the given aggregateFactory, based on the given inspector, which publishes events to the given eventBus and stores events in the given eventStore.
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.initialize(Callable<T> aggregateFactory, AggregateModel<T> inspector, EventBus eventBus, SnapshotTrigger snapshotTrigger) Initializes an EventSourcedAggregate instance using the given aggregateFactory, based on the given inspector, which publishes events to the given eventBus and stores events in the given eventStore.
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.initialize(T aggregateRoot, AggregateModel<T> inspector, EventBus eventBus, RepositoryProvider repositoryProvider, SnapshotTrigger snapshotTrigger) Initializes an EventSourcedAggregate instance for the given aggregateRoot, based on the given inspector, which publishes events to the given eventBus.
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.initialize(T aggregateRoot, AggregateModel<T> inspector, EventBus eventBus, SnapshotTrigger snapshotTrigger) Initializes an EventSourcedAggregate instance for the given aggregateRoot, based on the given inspector, which publishes events to the given eventBus.
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.reconstruct(T aggregateRoot, AggregateModel<T> model, long seqNo, boolean isDeleted, EventBus eventBus, RepositoryProvider repositoryProvider, SnapshotTrigger snapshotTrigger) Reconstructs an EventSourcedAggregate instance with given aggregateRoot.
static <T> EventSourcedAggregate<T>	EventSourcedAggregate.reconstruct(T aggregateRoot, AggregateModel<T> model, long seqNo, boolean isDeleted, EventBus eventBus, SnapshotTrigger snapshotTrigger) Reconstructs an EventSourcedAggregate instance with given aggregateRoot.

Constructors in org.axonframework.eventsourcing with parameters of type EventBus

Constructor and Description
EventSourcedAggregate(AggregateModel<T> model, EventBus eventBus, RepositoryProvider repositoryProvider, SnapshotTrigger snapshotTrigger) Creates a new EventSourcedAggregate instance based on the given model, which publishes events to the given eventBus.
EventSourcedAggregate(AggregateModel<T> model, EventBus eventBus, SnapshotTrigger snapshotTrigger) Creates a new EventSourcedAggregate instance based on the given model, which publishes events to the given eventBus.
EventSourcedAggregate(T aggregateRoot, AggregateModel<T> model, EventBus eventBus, RepositoryProvider repositoryProvider, SnapshotTrigger snapshotTrigger) Initializes an Aggregate instance for the given aggregateRoot, based on the given model, which publishes events to the given eventBus.
EventSourcedAggregate(T aggregateRoot, AggregateModel<T> model, EventBus eventBus, SnapshotTrigger snapshotTrigger) Initializes an Aggregate instance for the given aggregateRoot, based on the given model, which publishes events to the given eventBus.

Uses of EventBus in org.axonframework.eventsourcing.eventstore

Subinterfaces of EventBus in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface and Description
interface	EventStore Provides a mechanism to open streams from events in the the underlying event storage.

Classes in org.axonframework.eventsourcing.eventstore that implement EventBus

Modifier and Type	Class and Description
class	AbstractEventStore Abstract implementation of an EventStore that uses a EventStorageEngine to store and load events.
class	EmbeddedEventStore Implementation of an EventStore that stores and fetches events using an EventStorageEngine.

Uses of EventBus in org.axonframework.spring.config

Methods in org.axonframework.spring.config that return EventBus

Modifier and Type	Method and Description
EventBus	AxonConfiguration.defaultEventBus()
EventBus	AxonConfiguration.eventBus()

Uses of EventBus in org.axonframework.spring.eventhandling.scheduling.java

Methods in org.axonframework.spring.eventhandling.scheduling.java with parameters of type EventBus

Modifier and Type	Method and Description
void	SimpleEventSchedulerFactoryBean.setEventBus(EventBus eventBus) Sets the eventBus that scheduled events should be published to.

Uses of EventBus in org.axonframework.spring.eventhandling.scheduling.quartz

Methods in org.axonframework.spring.eventhandling.scheduling.quartz with parameters of type EventBus

Modifier and Type	Method and Description
void	QuartzEventSchedulerFactoryBean.setEventBus(EventBus eventBus) Sets the event bus to which scheduled events need to be published.

Uses of EventBus in org.axonframework.spring.messaging

Constructors in org.axonframework.spring.messaging with parameters of type EventBus

Constructor and Description
InboundEventMessageChannelAdapter(EventBus eventBus) Initialize an InboundEventMessageChannelAdapter instance that sends all incoming Event Messages to the given eventBus.

Uses of EventBus in org.axonframework.test.aggregate

Methods in org.axonframework.test.aggregate that return EventBus

Modifier and Type	Method and Description
EventBus	FixtureConfiguration.getEventBus() Returns the event bus used by this fixture.
EventBus	AggregateTestFixture.getEventBus()

Uses of EventBus in org.axonframework.test.saga

Constructors in org.axonframework.test.saga with parameters of type EventBus

Constructor and Description
EventValidator(EventBus eventBus, FieldFilter fieldFilter) Initializes the event validator to monitor the given eventBus.