Package | Description |
---|---|
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.async | |
org.axonframework.eventhandling.replay | |
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.quickstart.handler | |
org.axonframework.saga | |
org.axonframework.saga.annotation | |
org.axonframework.springmessaging.eventbus |
Contains the Event Bus implementation using Spring Messaging
|
org.axonframework.test.saga |
Modifier and Type | Interface and Description |
---|---|
interface |
EventListenerProxy
Specialist interface for implementations of an event listener that redirect actual processing to another instance.
|
Modifier and Type | Method and Description |
---|---|
Set<EventListener> |
Cluster.getMembers()
Returns a read-only view on the members in the cluster.
|
Set<EventListener> |
AbstractCluster.getMembers()
Returns a read-only view on the members in the cluster.
|
Modifier and Type | Method and Description |
---|---|
int |
EventListenerOrderComparator.compare(EventListener o1,
EventListener o2) |
Cluster |
ClassNamePatternClusterSelector.doSelectCluster(EventListener eventListener,
Class listenerType) |
Cluster |
ClassNamePrefixClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType) |
protected Cluster |
AnnotationClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType) |
protected abstract Cluster |
AbstractClusterSelector.doSelectCluster(EventListener eventListener,
Class<?> listenerType)
Select a cluster for the given
eventListener , which has the actual class listenerType . |
int |
SpringAnnotationOrderResolver.orderOf(EventListener listener) |
int |
OrderResolver.orderOf(EventListener listener)
Returns the order for the given
listener . |
void |
MultiplexingEventProcessingMonitor.prepareForInvocation(EventMessage eventMessage,
EventListener member)
Prepare the monitor for the invocation of the given
message to the given member . |
Cluster |
DefaultClusterSelector.selectCluster(EventListener eventListener)
Selects the cluster instance that the given
eventListener should be member of. |
Cluster |
CompositeClusterSelector.selectCluster(EventListener eventListener) |
Cluster |
ClusterSelector.selectCluster(EventListener eventListener)
Selects the cluster instance that the given
eventListener should be member of. |
Cluster |
AutowiringClusterSelector.selectCluster(EventListener eventListener) |
Cluster |
AbstractClusterSelector.selectCluster(EventListener eventListener) |
void |
SimpleEventBus.subscribe(EventListener eventListener)
Subscribe the given
eventListener to this bus. |
void |
EventBus.subscribe(EventListener eventListener)
Subscribe the given
eventListener to this bus. |
void |
ClusteringEventBus.subscribe(EventListener eventListener) |
void |
Cluster.subscribe(EventListener eventListener)
Subscribe the given
eventListener to this cluster. |
void |
AbstractCluster.subscribe(EventListener eventListener) |
void |
SimpleEventBus.unsubscribe(EventListener eventListener)
Unsubscribe the given
eventListener to this bus. |
void |
EventBus.unsubscribe(EventListener eventListener)
Unsubscribe the given
eventListener to this bus. |
void |
ClusteringEventBus.unsubscribe(EventListener eventListener) |
void |
Cluster.unsubscribe(EventListener eventListener)
Unsubscribes the given
eventListener from this cluster. |
void |
AbstractCluster.unsubscribe(EventListener eventListener) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleCluster.doPublish(List<EventMessage> events,
Set<EventListener> eventListeners,
MultiplexingEventProcessingMonitor monitor) |
protected abstract void |
AbstractCluster.doPublish(List<EventMessage> events,
Set<EventListener> eventListeners,
MultiplexingEventProcessingMonitor eventProcessingMonitor)
Publish the given list of
events to the given set of eventListeners , and notify the
given eventProcessingMonitor after completion. |
Constructor and Description |
---|
AbstractCluster(String name,
Comparator<EventListener> comparator)
Initializes the cluster with given
name , using given comparator to order the listeners
in the cluster. |
Modifier and Type | Class and Description |
---|---|
class |
AnnotationEventListenerAdapter
Adapter that turns any bean with
EventHandler annotated methods into an EventListener . |
Modifier and Type | Method and Description |
---|---|
protected Class<EventListener> |
AnnotationEventListenerBeanPostProcessor.getAdapterInterface() |
Modifier and Type | Method and Description |
---|---|
protected void |
AnnotationEventListenerBeanPostProcessor.subscribe(EventListener bean,
AnnotationEventListenerAdapter adapter) |
protected void |
AnnotationEventListenerBeanPostProcessor.unsubscribe(EventListener bean,
AnnotationEventListenerAdapter adapter) |
Modifier and Type | Method and Description |
---|---|
RetryPolicy |
ErrorHandler.handleError(Throwable exception,
EventMessage<?> eventMessage,
EventListener eventListener)
Invoked when a handler or the unit of work throws an exception.
|
RetryPolicy |
DefaultErrorHandler.handleError(Throwable exception,
EventMessage<?> eventMessage,
EventListener eventListener) |
Modifier and Type | Method and Description |
---|---|
protected void |
AsynchronousCluster.doPublish(List<EventMessage> events,
Set<EventListener> eventListeners,
MultiplexingEventProcessingMonitor eventProcessingMonitor) |
protected EventProcessor |
AsynchronousCluster.newProcessingScheduler(EventProcessor.ShutdownCallback shutDownCallback,
Set<EventListener> eventListeners,
MultiplexingEventProcessingMonitor eventProcessingMonitor)
Creates a new scheduler instance that schedules tasks on the executor service for the managed EventListener.
|
Constructor and Description |
---|
EventProcessor(Executor executor,
EventProcessor.ShutdownCallback shutDownCallback,
ErrorHandler errorHandler,
UnitOfWorkFactory unitOfWorkFactory,
Set<EventListener> eventListeners,
MultiplexingEventProcessingMonitor eventProcessingMonitor)
Initialize a scheduler using the given
executor . |
Modifier and Type | Method and Description |
---|---|
Set<EventListener> |
ReplayingCluster.getMembers() |
Modifier and Type | Method and Description |
---|---|
void |
ReplayingCluster.subscribe(EventListener eventListener)
Subscribe the given
eventListener to this cluster. |
void |
ReplayingCluster.unsubscribe(EventListener eventListener)
Unsubscribes the given
eventListener from this cluster. |
Modifier and Type | Method and Description |
---|---|
void |
SimpleEventBusWithoutStatistics.subscribe(EventListener eventListener) |
void |
SimpleEventBusWithoutStatistics.unsubscribe(EventListener eventListener) |
Modifier and Type | Class and Description |
---|---|
class |
EventListeningMessageChannelAdapter
Adapter class that sends Events from an event bus to a Spring Integration Message Channel.
|
Modifier and Type | Method and Description |
---|---|
void |
SpringIntegrationEventBus.subscribe(EventListener eventListener) |
void |
SpringIntegrationEventBus.unsubscribe(EventListener eventListener) |
Constructor and Description |
---|
MessageHandlerAdapter(EventListener eventListener)
Initialize an adapter for the given
eventListener . |
Modifier and Type | Class and Description |
---|---|
class |
ToDoEventListener
Event listener for all events, results are printed to system out.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SagaManager
Interface toward the Manager of one or more types of Saga.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSagaManager
Abstract implementation of the SagaManager interface that provides basic functionality required by most SagaManager
implementations.
|
class |
SimpleSagaManager
Simple SagaManager implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
AnnotatedSagaManager
Implementation of the SagaManager that uses annotations on the Sagas to describe the lifecycle management.
|
class |
AsyncAnnotatedSagaManager
A SagaManager implementation that processes Sagas asynchronously.
|
Modifier and Type | Method and Description |
---|---|
void |
SpringMessagingEventBus.subscribe(EventListener eventListener) |
void |
SpringMessagingEventBus.unsubscribe(EventListener eventListener) |
Constructor and Description |
---|
MessageHandlerAdapter(EventListener eventListener)
Initialize an adapter for the given
eventListener . |
Modifier and Type | Class and Description |
---|---|
class |
EventValidator
Helper class for validating events published on a given EventBus.
|
Copyright © 2010-2014. All Rights Reserved.