org.axonframework.saga.annotation
Class AsyncSagaEventProcessor

java.lang.Object
  org.axonframework.saga.annotation.AsyncSagaEventProcessor

All Implemented Interfaces:

com.lmax.disruptor.EventHandler<AsyncSagaProcessingEvent>, com.lmax.disruptor.LifecycleAware

public final class AsyncSagaEventProcessor
extends Object
implements com.lmax.disruptor.EventHandler<AsyncSagaProcessingEvent>, com.lmax.disruptor.LifecycleAware

Processes events by forwarding it to Saga instances "owned" by each processor. This processor uses a consistent hashing algorithm to assign the owner of each Saga.

Since:

2.0

Author:

Allard Buijze

Method Summary

void	onEvent(AsyncSagaProcessingEvent entry, long sequence, boolean endOfBatch)
void	onShutdown()
void	onStart()

Methods inherited from class java.lang.Object

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

Method Detail

onEvent

public void onEvent(AsyncSagaProcessingEvent entry,
                    long sequence,
                    boolean endOfBatch)
             throws Exception

Specified by:

onEvent in interface com.lmax.disruptor.EventHandler<AsyncSagaProcessingEvent>

Throws:

Exception

onStart

public void onStart()

Specified by:

onStart in interface com.lmax.disruptor.LifecycleAware

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface com.lmax.disruptor.LifecycleAware