|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EventBus | |
---|---|
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. |
Uses of EventBus in org.axonframework.commandhandling.disruptor |
---|
Methods in org.axonframework.commandhandling.disruptor with parameters of type EventBus | ||
---|---|---|
void |
DisruptorUnitOfWork.publishEvent(EventMessage event,
EventBus eventBus)
|
|
|
DisruptorUnitOfWork.registerAggregate(T aggregateRoot,
EventBus eventBus,
SaveAggregateCallback<T> saveAggregateCallback)
|
Constructors in org.axonframework.commandhandling.disruptor with parameters of type EventBus | |
---|---|
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 . |
Uses of EventBus in org.axonframework.contextsupport.spring |
---|
Methods in org.axonframework.contextsupport.spring with parameters of type EventBus | |
---|---|
void |
SagaManagerBeanDefinitionParser.SagaManagerLifecycleManager.setEventBus(EventBus eventBus)
Sets the event bus to which the SagaManager should be subscribed |
Uses of EventBus in org.axonframework.eventhandling |
---|
Classes in org.axonframework.eventhandling that implement EventBus | |
---|---|
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. |
Constructors in org.axonframework.eventhandling with parameters of type EventBus | |
---|---|
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 . |
Uses of EventBus in org.axonframework.eventhandling.annotation |
---|
Methods in org.axonframework.eventhandling.annotation with parameters of type EventBus | |
---|---|
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 . |
Constructors in org.axonframework.eventhandling.annotation with parameters of type EventBus | |
---|---|
AnnotationEventListenerAdapter(Object annotatedEventListener,
EventBus eventBus)
Deprecated. Use AnnotationEventListenerAdapter.AnnotationEventListenerAdapter(Object) and subscribe the listener to the event bus
using subscribe(org.axonframework.eventhandling.EventListener) |
Uses of EventBus in org.axonframework.eventhandling.scheduling.java |
---|
Methods in org.axonframework.eventhandling.scheduling.java with parameters of type EventBus | |
---|---|
void |
SimpleEventSchedulerFactoryBean.setEventBus(EventBus eventBus)
Sets the eventBus that scheduled events should be published to. |
Constructors in org.axonframework.eventhandling.scheduling.java with parameters of type EventBus | |
---|---|
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 . |
Uses of EventBus in org.axonframework.eventhandling.scheduling.quartz |
---|
Methods in org.axonframework.eventhandling.scheduling.quartz with parameters of type EventBus | |
---|---|
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. |
Uses of EventBus in org.axonframework.gae.commandhandling |
---|
Classes in org.axonframework.gae.commandhandling that implement EventBus | |
---|---|
class |
SimpleEventBusWithoutStatistics
This is a temporary copy of the SimpleEventBus, made to run on google app engine. |
Uses of EventBus in org.axonframework.integration.adapter |
---|
Constructors in org.axonframework.integration.adapter with parameters of type EventBus | |
---|---|
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 . |
Uses of EventBus in org.axonframework.integration.eventbus |
---|
Classes in org.axonframework.integration.eventbus that implement EventBus | |
---|---|
class |
SpringIntegrationEventBus
EventBus implementation that delegates all subscription and publishing
requests to a Spring Integration channel . |
Uses of EventBus in org.axonframework.repository |
---|
Methods in org.axonframework.repository with parameters of type EventBus | |
---|---|
void |
AbstractRepository.setEventBus(EventBus eventBus)
Sets the event bus to which newly stored events should be published. |
Uses of EventBus in org.axonframework.saga |
---|
Uses of EventBus in org.axonframework.saga.annotation |
---|
Uses of EventBus in org.axonframework.springmessaging.adapter |
---|
Constructors in org.axonframework.springmessaging.adapter with parameters of type EventBus | |
---|---|
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 . |
Uses of EventBus in org.axonframework.springmessaging.eventbus |
---|
Classes in org.axonframework.springmessaging.eventbus that implement EventBus | |
---|---|
class |
SpringMessagingEventBus
EventBus implementation that delegates all subscription and publishing
requests to a Spring Messaging channel . |
Uses of EventBus in org.axonframework.test |
---|
Methods in org.axonframework.test that return EventBus | |
---|---|
EventBus |
GivenWhenThenTestFixture.getEventBus()
|
EventBus |
FixtureConfiguration.getEventBus()
Returns the event bus used by this fixture. |
Uses of EventBus in org.axonframework.test.saga |
---|
Constructors in org.axonframework.test.saga with parameters of type EventBus | |
---|---|
EventValidator(EventBus eventBus,
FieldFilter fieldFilter)
Initializes the event validator to monitor the given eventBus . |
Uses of EventBus in org.axonframework.unitofwork |
---|
Methods in org.axonframework.unitofwork with parameters of type EventBus | ||
---|---|---|
void |
UnitOfWork.publishEvent(EventMessage<?> event,
EventBus eventBus)
Request to publish the given event on the given eventBus . |
|
void |
NestableUnitOfWork.publishEvent(EventMessage<?> event,
EventBus eventBus)
|
|
|
UnitOfWork.registerAggregate(T aggregateRoot,
EventBus eventBus,
SaveAggregateCallback<T> saveAggregateCallback)
Register an aggregate with this UnitOfWork. |
|
|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |