org.axonframework.eventhandling.async
Class SequentialPerAggregatePolicy

java.lang.Object
  org.axonframework.eventhandling.async.SequentialPerAggregatePolicy

All Implemented Interfaces:

SequencingPolicy<EventMessage>

public class SequentialPerAggregatePolicy
extends Object
implements SequencingPolicy<EventMessage>

Concurrency policy that requires sequential processing of events raised by the same aggregate. Events from different aggregates may be processed in different threads, as will events that do not extend the DomainEvent type.

Since:

0.3

Author:

Allard Buijze

Constructor Summary

SequentialPerAggregatePolicy()

Method Summary

Object

getSequenceIdentifierFor(EventMessage event) Returns the sequence identifier for the given event.

Methods inherited from class java.lang.Object

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

Constructor Detail

SequentialPerAggregatePolicy

public SequentialPerAggregatePolicy()

Method Detail

getSequenceIdentifierFor

public Object getSequenceIdentifierFor(EventMessage event)

Returns the sequence identifier for the given event. When two events have the same identifier (as defined by their equals method), they will be executed sequentially. A null value indicates that there are no sequencing requirements for the handling of this event.

Specified by:

getSequenceIdentifierFor in interface SequencingPolicy<EventMessage>

Parameters:

event - the event for which to get the sequencing identifier

Returns:

a sequence identifier for the given event