org.axonframework.eventhandling.async

Class EventProcessor

java.lang.Object

org.axonframework.eventhandling.async.EventProcessor

All Implemented Interfaces:

Runnable

public class EventProcessor
extends Object
implements Runnable

Scheduler that keeps track of (Event processing) tasks that need to be executed sequentially.

Since:

1.0

Author:

Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	EventProcessor.ShutdownCallback Callback that allows the SequenceManager to receive a notification when this scheduler finishes processing events.

Constructor Summary

Constructors

Constructor and Description
EventProcessor(Executor executor, EventProcessor.ShutdownCallback shutDownCallback, ErrorHandler errorHandler, UnitOfWorkFactory unitOfWorkFactory, Collection<EventListener> eventListeners) Initialize a scheduler using the given executor.

Method Summary

Methods

Modifier and Type	Method and Description
protected RetryPolicy	doHandle(EventMessage<?> event) Does the actual processing of the event.
void	run()
boolean	scheduleEvent(EventMessage<?> event) Schedules an event for processing.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventProcessor

public EventProcessor(Executor executor,
              EventProcessor.ShutdownCallback shutDownCallback,
              ErrorHandler errorHandler,
              UnitOfWorkFactory unitOfWorkFactory,
              Collection<EventListener> eventListeners)

Initialize a scheduler using the given executor. This scheduler uses an unbounded queue to schedule events.

Parameters:

executor - The executor service that will process the events

shutDownCallback - The callback to notify when the scheduler finishes processing events

errorHandler - The error handler to invoke when an error occurs while committing a Unit of Work

unitOfWorkFactory - The factory providing instances of the Unit of Work

eventListeners - The event listeners that should handle incoming events

Method Detail

scheduleEvent

public boolean scheduleEvent(EventMessage<?> event)

Schedules an event for processing. Will schedule a new invoker task if none is currently active.

If the current scheduler is in the process of being shut down, this method will return false.

This method is thread safe

Parameters:

event - the event to schedule

Returns:

true if the event was scheduled successfully, false if this scheduler is not available to process events

Throws:

IllegalStateException - if the queue in this scheduler does not have the capacity to add this event

run

public void run()

Specified by:

run in interface Runnable

doHandle

protected RetryPolicy doHandle(EventMessage<?> event)

Does the actual processing of the event. This method is invoked if the scheduler has decided this event is up next for execution. Implementation should not pass this scheduling to an asynchronous executor

Parameters:

event - The event to handle

Returns:

the policy for retrying/proceeding with this event