Package | Description |
---|---|
org.axonframework.commandhandling.disruptor | |
org.axonframework.contextsupport.spring | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.annotation |
Classes in support of the configuration of Event Handlers using annotations.
|
org.axonframework.eventhandling.scheduling.java | |
org.axonframework.eventhandling.scheduling.quartz | |
org.axonframework.gae.commandhandling | |
org.axonframework.integration.adapter |
Utility classes used to connect an Event Bus to a Spring Integration Channel.
|
org.axonframework.integration.eventbus |
Contains the Event Bus implementation using Spring Integration
|
org.axonframework.repository |
Classes related to the repository interface and implementations.
|
org.axonframework.saga | |
org.axonframework.saga.annotation | |
org.axonframework.springmessaging.adapter |
Utility classes used to connect an Event Bus to a Spring Messaging Channel.
|
org.axonframework.springmessaging.eventbus |
Contains the Event Bus implementation using Spring Messaging
|
org.axonframework.test |
Classes in support of testing Axon based applications.
|
org.axonframework.test.saga | |
org.axonframework.unitofwork |
Classes in support of the UnitOfWork pattern in Axon Framework.
|
Modifier and Type | Method and Description |
---|---|
void |
DisruptorUnitOfWork.publishEvent(EventMessage event,
EventBus eventBus) |
<T extends AggregateRoot> |
DisruptorUnitOfWork.registerAggregate(T aggregateRoot,
EventBus eventBus,
SaveAggregateCallback<T> saveAggregateCallback) |
Constructor and Description |
---|
DisruptorCommandBus(EventStore eventStore,
EventBus eventBus)
Initialize the DisruptorCommandBus with given resources, using default configuration settings.
|
DisruptorCommandBus(EventStore eventStore,
EventBus eventBus,
DisruptorConfiguration configuration)
Initialize the DisruptorCommandBus with given resources and settings.
|
EventPublisher(EventStore eventStore,
EventBus eventBus,
Executor executor,
TransactionManager transactionManager,
RollbackConfiguration rollbackConfiguration,
int segmentId)
Initializes the EventPublisher to publish Events to the given
eventStore and eventBus
for aggregate of given aggregateType . |
Modifier and Type | Method and Description |
---|---|
void |
SagaManagerBeanDefinitionParser.SagaManagerLifecycleManager.setEventBus(EventBus eventBus)
Sets the event bus to which the SagaManager should be subscribed
|
Modifier and Type | Class and Description |
---|---|
class |
ClusteringEventBus
EventBus implementation that supports clustering of Event Listeners. |
class |
SimpleEventBus
Implementation of the
EventBus that directly forwards all published events (in the callers' thread) to all
subscribed listeners. |
Constructor and Description |
---|
EventTemplate(EventBus eventBus)
Initialize the template to publish Events through the given
eventBus . |
EventTemplate(EventBus eventBus,
Map<String,?> additionalMetaData)
Initialize the template to publish Events through the given
eventBus . |
Modifier and Type | Method and Description |
---|---|
void |
AnnotationEventListenerBeanPostProcessor.setEventBus(EventBus eventBus)
Sets the event bus to which detected event listeners should be subscribed.
|
static AnnotationEventListenerAdapter |
AnnotationEventListenerAdapter.subscribe(Object annotatedEventListener,
EventBus eventBus)
Subscribe the given
annotatedEventListener to the given eventBus . |
Constructor and Description |
---|
AnnotationEventListenerAdapter(Object annotatedEventListener,
EventBus eventBus)
Deprecated.
Use
AnnotationEventListenerAdapter.AnnotationEventListenerAdapter(Object) and subscribe the listener to the event bus
using subscribe(org.axonframework.eventhandling.EventListener) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleEventSchedulerFactoryBean.setEventBus(EventBus eventBus)
Sets the eventBus that scheduled events should be published to.
|
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,
UnitOfWorkFactory unitOfWorkFactory)
Initialize the SimpleEventScheduler using the given
executorService as trigger and execution
mechanism, and publishes events to the given eventBus . |
Modifier and Type | Method and Description |
---|---|
void |
QuartzEventSchedulerFactoryBean.setEventBus(EventBus eventBus)
Sets the event bus to which scheduled events need to be published.
|
void |
QuartzEventScheduler.setEventBus(EventBus eventBus)
Sets the event bus to which scheduled events need to be published.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleEventBusWithoutStatistics
This is a temporary copy of the SimpleEventBus, made to run on google app engine.
|
Constructor and Description |
---|
EventListeningMessageChannelAdapter(EventBus eventBus,
org.springframework.integration.MessageChannel channel)
Initialize an adapter to forward messages from the given
eventBus to the given
channel . |
EventListeningMessageChannelAdapter(EventBus eventBus,
org.springframework.integration.MessageChannel channel,
EventFilter filter)
Initialize an adapter to forward messages from the given
eventBus to the given
channel . |
EventPublishingMessageChannelAdapter(EventBus eventBus)
Initialize the adapter to publish all incoming events to the given
eventBus . |
EventPublishingMessageChannelAdapter(EventBus eventBus,
EventFilter filter)
Initialize the adapter to publish all incoming events to the given
eventBus if they accepted by the
given filter . |
Modifier and Type | Class and Description |
---|---|
class |
SpringIntegrationEventBus
EventBus implementation that delegates all subscription and publishing
requests to a Spring Integration channel . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRepository.setEventBus(EventBus eventBus)
Sets the event bus to which newly stored events should be published.
|
Constructor and Description |
---|
AbstractSagaManager(EventBus eventBus,
SagaRepository sagaRepository,
SagaFactory sagaFactory,
Class<? extends Saga>... sagaTypes)
Deprecated.
|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver,
EventBus eventBus)
Deprecated.
|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver,
SagaFactory sagaFactory,
EventBus eventBus)
|
Constructor and Description |
---|
EventListeningMessageChannelAdapter(EventBus eventBus,
org.springframework.messaging.MessageChannel channel)
Initialize an adapter to forward messages from the given
eventBus to the given
channel . |
EventListeningMessageChannelAdapter(EventBus eventBus,
org.springframework.messaging.MessageChannel channel,
EventFilter filter)
Initialize an adapter to forward messages from the given
eventBus to the given
channel . |
EventPublishingMessageChannelAdapter(EventBus eventBus)
Initialize the adapter to publish all incoming events to the given
eventBus . |
EventPublishingMessageChannelAdapter(EventBus eventBus,
EventFilter filter)
Initialize the adapter to publish all incoming events to the given
eventBus if they accepted by the
given filter . |
Modifier and Type | Class and Description |
---|---|
class |
SpringMessagingEventBus
EventBus implementation that delegates all subscription and publishing
requests to a Spring Messaging channel . |
Modifier and Type | Method and Description |
---|---|
EventBus |
GivenWhenThenTestFixture.getEventBus() |
EventBus |
FixtureConfiguration.getEventBus()
Returns the event bus used by this fixture.
|
Constructor and Description |
---|
EventValidator(EventBus eventBus)
Initializes the event validator to monitor the given
eventBus . |
Modifier and Type | Method and Description |
---|---|
void |
UnitOfWork.publishEvent(EventMessage<?> event,
EventBus eventBus)
Request to publish the given
event on the given eventBus . |
void |
NestableUnitOfWork.publishEvent(EventMessage<?> event,
EventBus eventBus) |
<T extends AggregateRoot> |
UnitOfWork.registerAggregate(T aggregateRoot,
EventBus eventBus,
SaveAggregateCallback<T> saveAggregateCallback)
Register an aggregate with this UnitOfWork.
|
<T extends AggregateRoot> |
DefaultUnitOfWork.registerAggregate(T aggregate,
EventBus eventBus,
SaveAggregateCallback<T> saveAggregateCallback) |
protected abstract void |
NestableUnitOfWork.registerForPublication(EventMessage<?> event,
EventBus eventBus,
boolean notifyRegistrationHandlers)
Register the given
event for publication on the given eventBus when the unit of work
is committed. |
void |
DefaultUnitOfWork.registerForPublication(EventMessage<?> event,
EventBus eventBus,
boolean notifyRegistrationHandlers) |
Copyright © 2010-2014. All Rights Reserved.