| Package | Description |
|---|---|
| org.axonframework.axonserver.connector.event.axon | |
| 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.modelling.command | |
| org.axonframework.modelling.command.inspection | |
| 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 |
| Modifier and Type | Class and Description |
|---|---|
class |
AxonServerEventStore
Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
default Configurer |
Configurer.configureEventBus(Function<Configuration,EventBus> eventBusBuilder)
Configures the given Event Bus to use in this configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractEventBus
Base class for the Event Bus.
|
class |
SimpleEventBus
Implementation of the
EventBus that dispatches events in the thread the publishes them. |
| Modifier and Type | Method and Description |
|---|---|
SimpleEventScheduler.Builder |
SimpleEventScheduler.Builder.eventBus(EventBus eventBus)
Sets the
EventBus used to publish events on to, once the schedule has been met. |
| Modifier and Type | Method and Description |
|---|---|
QuartzEventScheduler.Builder |
QuartzEventScheduler.Builder.eventBus(EventBus eventBus)
Sets the
EventBus used to publish events on once the schedule has been met. |
| 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. |
| 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. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
EventStore
Provides a mechanism to open streams from events in the the underlying event storage.
|
| 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. |
| Modifier and Type | Method and Description |
|---|---|
GenericJpaRepository.Builder<T> |
GenericJpaRepository.Builder.eventBus(EventBus eventBus)
Sets the
EventBus to which events are published. |
| 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. |
| 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. |
| Modifier and Type | Method and Description |
|---|---|
EventBus |
AxonConfiguration.defaultEventBus() |
EventBus |
AxonConfiguration.eventBus() |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleEventSchedulerFactoryBean.setEventBus(EventBus eventBus)
Sets the eventBus that scheduled events should be published to.
|
| Modifier and Type | Method and Description |
|---|---|
void |
QuartzEventSchedulerFactoryBean.setEventBus(EventBus eventBus)
Sets the event bus to which scheduled events need to be published.
|
| Constructor and Description |
|---|
InboundEventMessageChannelAdapter(EventBus eventBus)
Initialize an InboundEventMessageChannelAdapter instance that sends all incoming Event Messages to the given
eventBus. |
| Modifier and Type | Method and Description |
|---|---|
EventBus |
AggregateTestFixture.getEventBus() |
EventBus |
FixtureConfiguration.getEventBus()
Returns the event bus used by this fixture.
|
| Constructor and Description |
|---|
EventValidator(EventBus eventBus,
FieldFilter fieldFilter)
Initializes the event validator to monitor the given
eventBus. |
Copyright © 2010–2018. All rights reserved.