org.axonframework.unitofwork

Class NestableUnitOfWork

java.lang.Object

org.axonframework.unitofwork.NestableUnitOfWork

All Implemented Interfaces:

UnitOfWork

Direct Known Subclasses:

DefaultUnitOfWork

public abstract class NestableUnitOfWork
extends Object
implements UnitOfWork

Abstract implementation of the UnitOfWork interface. Provides the necessary implementations to support most actions required by any Unit of Work, such as managing registration with the CurrentUnitOfWork and support for nesting a Unit of Work.

Since:

0.7

Author:

Allard Buijze

See Also:

CurrentUnitOfWork

Constructor Summary

Constructors

Constructor and Description
NestableUnitOfWork()

Method Summary

Methods

Modifier and Type	Method and Description
void	commit() Commits the UnitOfWork.
protected void	commitInnerUnitOfWork() Commit all registered inner units of work.
protected abstract void	doCommit() Executes the logic required to commit this unit of work.
protected abstract void	doRollback(Throwable cause) Executes the logic required to commit this unit of work.
protected abstract void	doStart() Performs logic required when starting this UnitOfWork instance.
boolean	isStarted() Indicates whether this UnitOfWork is started.
protected abstract void	notifyListenersCleanup() Send a UnitOfWorkListener.onCleanup(UnitOfWork) notification to all registered listeners.
protected abstract void	notifyListenersPrepareCommit() Send a UnitOfWorkListener.onPrepareCommit(UnitOfWork, java.util.Set, java.util.List) notification to all registered listeners.
protected abstract void	notifyListenersRollback(Throwable cause) Send a UnitOfWorkListener.onRollback(UnitOfWork, Throwable) notification to all registered listeners.
void	publishEvent(EventMessage<?> event, EventBus eventBus) Request to publish the given event on the given eventBus.
protected abstract void	registerForPublication(EventMessage<?> event, EventBus eventBus) Register the given event for publication on the given eventBus when the unit of work is committed.
void	rollback() Clear the UnitOfWork of any buffered changes.
void	rollback(Throwable cause) Clear the UnitOfWork of any buffered changes.
protected abstract void	saveAggregates() Saves all registered aggregates by calling their respective callbacks.
void	start() Starts the current unit of work, preparing it for aggregate registration.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.unitofwork.UnitOfWork

isTransactional, registerAggregate, registerListener

Constructor Detail

NestableUnitOfWork

public NestableUnitOfWork()

Method Detail

commit

public void commit()

Description copied from interface: UnitOfWork

Commits the UnitOfWork. All registered aggregates that have not been registered as stored are saved in their respective repositories, buffered events are sent to their respective event bus, and all registered UnitOfWorkListeners are notified.

After the commit (successful or not), the UnitOfWork is unregistered from the CurrentUnitOfWork and has cleaned up all resources it occupied. This effectively means that a rollback is done if Unit Of Work failed to commit.

Specified by:

commit in interface UnitOfWork

notifyListenersCleanup

protected abstract void notifyListenersCleanup()

Send a UnitOfWorkListener.onCleanup(UnitOfWork) notification to all registered listeners. The implementation must ensure that all listeners are notified, even if one throws an exception.

notifyListenersRollback

protected abstract void notifyListenersRollback(Throwable cause)

Send a UnitOfWorkListener.onRollback(UnitOfWork, Throwable) notification to all registered listeners.

Parameters:

cause - The cause of the rollback

rollback

public void rollback()

Description copied from interface: UnitOfWork

Clear the UnitOfWork of any buffered changes. All buffered events and registered aggregates are discarded and registered UnitOfWorkListeners are notified.

If the rollback is a result of an exception, consider using UnitOfWork.rollback(Throwable) instead.

Specified by:

rollback in interface UnitOfWork

rollback

public void rollback(Throwable cause)

Description copied from interface: UnitOfWork

Clear the UnitOfWork of any buffered changes. All buffered events and registered aggregates are discarded and registered UnitOfWorkListeners are notified.

Specified by:

rollback in interface UnitOfWork

Parameters:

cause - The cause of the rollback. May be null.

start

public void start()

Description copied from interface: UnitOfWork

Starts the current unit of work, preparing it for aggregate registration. The UnitOfWork instance is registered with the CurrentUnitOfWork.

Specified by:

start in interface UnitOfWork

publishEvent

public void publishEvent(EventMessage<?> event,
                EventBus eventBus)

Description copied from interface: UnitOfWork

Request to publish the given event on the given eventBus. The UnitOfWork may either publish immediately, or buffer the events until the UnitOfWork is committed.

Specified by:

publishEvent in interface UnitOfWork

Parameters:

event - The event to be published on the event bus

eventBus - The event bus on which to publish the event

registerForPublication

protected abstract void registerForPublication(EventMessage<?> event,
                          EventBus eventBus)

Register the given event for publication on the given eventBus when the unit of work is committed. This method will only be invoked on the outer unit of work, as that one is responsible for maintaining the order of publication of events.

Parameters:

event - The Event to publish

eventBus - The Event Bus to publish the Event on

isStarted

public boolean isStarted()

Description copied from interface: UnitOfWork

Indicates whether this UnitOfWork is started. It is started when the UnitOfWork.start() method has been called, and if the UnitOfWork has not been committed or rolled back.

Specified by:

isStarted in interface UnitOfWork

Returns:

true if this UnitOfWork is started, false otherwise.

doStart

protected abstract void doStart()

Performs logic required when starting this UnitOfWork instance.

doCommit

protected abstract void doCommit()

Executes the logic required to commit this unit of work.

doRollback

protected abstract void doRollback(Throwable cause)

Executes the logic required to commit this unit of work.

Parameters:

cause - the cause of the rollback

commitInnerUnitOfWork

protected void commitInnerUnitOfWork()

Commit all registered inner units of work. This should be invoked after events have been dispatched and before any listeners are notified of the commit.

saveAggregates

protected abstract void saveAggregates()

Saves all registered aggregates by calling their respective callbacks.

notifyListenersPrepareCommit

protected abstract void notifyListenersPrepareCommit()

Send a UnitOfWorkListener.onPrepareCommit(UnitOfWork, java.util.Set, java.util.List) notification to all registered listeners.