org.axonframework.saga

Class AbstractReplayAwareSagaManager

java.lang.Object

org.axonframework.saga.AbstractReplayAwareSagaManager

All Implemented Interfaces:

EventListener, EventListenerProxy, ReplayAware, SagaManager

Direct Known Subclasses:

AbstractSagaManager, AsyncAnnotatedSagaManager

public abstract class AbstractReplayAwareSagaManager
extends Object
implements SagaManager, ReplayAware

Abstract implementation of the SagaManager interface that provides basic functionality required by most SagaManager implementations. Provides support for dealing with event replays.

Since:

2.4.3

Author:

Rene de Waele

Constructor Summary

Constructors

Constructor and Description
AbstractReplayAwareSagaManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterReplay() Invoked when a replay has finished.
void	beforeReplay() Invoked when a replay is started.
void	onReplayFailed(Throwable cause) Invoked when a replay has failed due to an exception.
void	setReplayable(boolean replayable) Sets whether or not to allow event replay on managed Sagas.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.saga.SagaManager

handle

Methods inherited from interface org.axonframework.eventhandling.EventListenerProxy

getTargetType

Constructor Detail

AbstractReplayAwareSagaManager

public AbstractReplayAwareSagaManager()

Method Detail

setReplayable

public void setReplayable(boolean replayable)

Sets whether or not to allow event replay on managed Sagas. If set to false the saga manager will throw an IllegalStateException before a replay is started. Defaults to false.

Parameters:

replayable - whether or not to allow event replays on managed Sagas.

beforeReplay

public void beforeReplay()

Description copied from interface: ReplayAware

Invoked when a replay is started.

Specified by:

beforeReplay in interface ReplayAware

afterReplay

public void afterReplay()

Description copied from interface: ReplayAware

Invoked when a replay has finished.

Specified by:

afterReplay in interface ReplayAware

onReplayFailed

public void onReplayFailed(Throwable cause)

Description copied from interface: ReplayAware

Invoked when a replay has failed due to an exception.

Specified by:

onReplayFailed in interface ReplayAware

Parameters:

cause - The exception that stopped the replay;