org.axonframework.eventhandling

Class SubscribingEventProcessor

java.lang.Object

org.axonframework.eventhandling.AbstractEventProcessor

org.axonframework.eventhandling.SubscribingEventProcessor

All Implemented Interfaces:

EventProcessor

public class SubscribingEventProcessor
extends AbstractEventProcessor

Event processor implementation that subscribes to the EventBus for events. Events published on the event bus are supplied to this processor in the publishing thread.

Depending on the given EventProcessingStrategy the events are processed directly (in the publishing thread) or asynchronously.

Author:

Rene de Waele

Constructor Summary

Constructors

Constructor and Description
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, RollbackConfiguration rollbackConfiguration, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<EventMessage<?>> messageSource) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.
SubscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<EventMessage<?>> messageSource, EventProcessingStrategy processingStrategy, ErrorHandler errorHandler) Initializes an EventProcessor with given name that subscribes to the given messageSource for events.

Method Summary

Modifier and Type	Method and Description
protected void	process(List<? extends EventMessage<?>> eventMessages) Process the given messages.
void	shutDown() Shut down this processor.
void	start() Start this processor.

Methods inherited from class org.axonframework.eventhandling.AbstractEventProcessor

canHandle, getName, processInUnitOfWork, registerInterceptor, reportIgnored, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SubscribingEventProcessor

public SubscribingEventProcessor(String name,
                                 EventHandlerInvoker eventHandlerInvoker,
                                 SubscribableMessageSource<EventMessage<?>> messageSource)

Initializes an EventProcessor with given name that subscribes to the given messageSource for events. Actual handling of event messages is deferred to the given eventHandlerInvoker.

The EventProcessor is initialized with a DirectEventProcessingStrategy, a PropagatingErrorHandler and a RollbackConfigurationType.ANY_THROWABLE.

Parameters:

name - The name of the event processor

eventHandlerInvoker - The component that handles the individual events

messageSource - The EventBus to which this event processor will subscribe

SubscribingEventProcessor

public SubscribingEventProcessor(String name,
                                 EventHandlerInvoker eventHandlerInvoker,
                                 SubscribableMessageSource<EventMessage<?>> messageSource,
                                 EventProcessingStrategy processingStrategy,
                                 ErrorHandler errorHandler)

Initializes an EventProcessor with given name that subscribes to the given messageSource for events. Actual handling of event messages is deferred to the given eventHandlerInvoker.

The EventProcessor is initialized with a DirectEventProcessingStrategy, a PropagatingErrorHandler and a RollbackConfigurationType.ANY_THROWABLE.

Parameters:

name - The name of the event processor

eventHandlerInvoker - The component that handles the individual events

messageSource - The EventBus to which this event processor will subscribe

processingStrategy - Strategy that determines whether events are processed directly or asynchronously

errorHandler - The handler to invoke when an error occurs in the processor

SubscribingEventProcessor

public SubscribingEventProcessor(String name,
                                 EventHandlerInvoker eventHandlerInvoker,
                                 SubscribableMessageSource<? extends EventMessage<?>> messageSource,
                                 EventProcessingStrategy processingStrategy,
                                 ErrorHandler errorHandler,
                                 MessageMonitor<? super EventMessage<?>> messageMonitor)

Initializes an EventProcessor with given name that subscribes to the given messageSource for events. Actual handling of event messages is deferred to the given eventHandlerInvoker.

The EventProcessor is initialized with a DirectEventProcessingStrategy, a PropagatingErrorHandler and a RollbackConfigurationType.ANY_THROWABLE.

Parameters:

name - The name of the event processor

eventHandlerInvoker - The component that handles the individual events

messageSource - The EventBus to which this event processor will subscribe

processingStrategy - Strategy that determines whether events are processed directly or asynchronously

errorHandler - The handler to invoke when an error occurs in the processor

messageMonitor - Monitor to be invoked before and after event processing

SubscribingEventProcessor

public SubscribingEventProcessor(String name,
                                 EventHandlerInvoker eventHandlerInvoker,
                                 RollbackConfiguration rollbackConfiguration,
                                 SubscribableMessageSource<? extends EventMessage<?>> messageSource,
                                 EventProcessingStrategy processingStrategy,
                                 ErrorHandler errorHandler,
                                 MessageMonitor<? super EventMessage<?>> messageMonitor)

Initializes an EventProcessor with given name that subscribes to the given messageSource for events. Actual handling of event messages is deferred to the given eventHandlerInvoker.

Parameters:

name - The name of the event processor

eventHandlerInvoker - The component that handles the individual events

rollbackConfiguration - Determines rollback behavior of the UnitOfWork while processing a batch of events

messageSource - The EventBus to which this event processor will subscribe

processingStrategy - Strategy that determines whether events are processed directly or asynchronously

errorHandler - Invoked when a UnitOfWork is rolled back during processing

messageMonitor - Monitor to be invoked before and after event processing

Method Detail

start

public void start()

Start this processor. This will register the processor with the EventBus.

process

protected void process(List<? extends EventMessage<?>> eventMessages)

Process the given messages. A Unit of Work must be created for this processing.

This implementation creates a Batching unit of work for the given batch of eventMessages.

Parameters:

eventMessages - The messages to process

shutDown

public void shutDown()

Shut down this processor. This will deregister the processor with the EventBus.