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 |
---|---|
EventBus |
AbstractEventGateway.getEventBus()
Returns the EventBus used by this EventGateway.
|
Modifier and Type | Method and Description |
---|---|
DefaultEventGateway.Builder |
DefaultEventGateway.Builder.eventBus(EventBus eventBus) |
AbstractEventGateway.Builder |
AbstractEventGateway.Builder.eventBus(EventBus eventBus)
Sets the
EventBus used to publish events. |
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.
|
Modifier and Type | Method and Description |
---|---|
EventBus |
FixtureConfiguration.getEventBus()
Returns the event bus used by this fixture.
|
EventBus |
SagaTestFixture.getEventBus() |
Constructor and Description |
---|
EventValidator(EventBus eventBus,
FieldFilter fieldFilter)
Initializes the event validator to monitor the given
eventBus . |
Copyright © 2010–2019. All rights reserved.