Package | Description |
---|---|
org.axonframework.disruptor.commandhandling | |
org.axonframework.messaging.unitofwork |
Modifier and Type | Method and Description |
---|---|
protected void |
DisruptorUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
protected void |
DisruptorUnitOfWork.notifyHandlers(UnitOfWork.Phase phase) |
Modifier and Type | Method and Description |
---|---|
UnitOfWork.Phase |
UnitOfWork.phase()
Returns the current phase of the Unit of Work.
|
UnitOfWork.Phase |
AbstractUnitOfWork.phase() |
static UnitOfWork.Phase |
UnitOfWork.Phase.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static UnitOfWork.Phase[] |
UnitOfWork.Phase.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageProcessingContext.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler)
Adds a handler to the collection.
|
protected void |
DefaultUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
protected void |
BatchingUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
protected abstract void |
AbstractUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler)
Register the given
handler with the Unit of Work. |
protected void |
AbstractUnitOfWork.changePhase(UnitOfWork.Phase... phases)
Ask the unit of work to transition to the given
phases sequentially. |
boolean |
UnitOfWork.Phase.isAfter(UnitOfWork.Phase phase)
Check if this Phase comes after given other
phase . |
boolean |
UnitOfWork.Phase.isBefore(UnitOfWork.Phase phase)
Check if this Phase comes before given other
phase . |
protected void |
DefaultUnitOfWork.notifyHandlers(UnitOfWork.Phase phase) |
protected void |
BatchingUnitOfWork.notifyHandlers(UnitOfWork.Phase phase) |
protected abstract void |
AbstractUnitOfWork.notifyHandlers(UnitOfWork.Phase phase)
Notify the handlers attached to the given
phase . |
void |
MessageProcessingContext.notifyHandlers(UnitOfWork<T> unitOfWork,
UnitOfWork.Phase phase)
Invoke the handlers in this collection attached to the given
phase . |
protected void |
AbstractUnitOfWork.setPhase(UnitOfWork.Phase phase)
Overwrite the current phase with the given
phase . |
Copyright © 2010–2022. All rights reserved.