Package org.apache.camel.impl.engine
Class DefaultUnitOfWork
- java.lang.Object
-
- org.apache.camel.impl.engine.DefaultUnitOfWork
-
- All Implemented Interfaces:
org.apache.camel.spi.UnitOfWork
- Direct Known Subclasses:
MDCUnitOfWork
public class DefaultUnitOfWork extends Object implements org.apache.camel.spi.UnitOfWork
The default implementation ofUnitOfWork
-
-
Constructor Summary
Constructors Modifier Constructor Description DefaultUnitOfWork(org.apache.camel.Exchange exchange)
DefaultUnitOfWork(org.apache.camel.Exchange exchange, org.apache.camel.spi.InflightRepository inflightRepository, boolean allowUseOriginalMessage, boolean useBreadcrumb)
protected
DefaultUnitOfWork(org.apache.camel.Exchange exchange, org.slf4j.Logger logger, org.apache.camel.spi.InflightRepository inflightRepository, boolean allowUseOriginalMessage, boolean useBreadcrumb)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addSynchronization(org.apache.camel.spi.Synchronization synchronization)
void
afterProcess(org.apache.camel.Processor processor, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, boolean doneSync)
void
afterRoute(org.apache.camel.Exchange exchange, org.apache.camel.Route route)
org.apache.camel.AsyncCallback
beforeProcess(org.apache.camel.Processor processor, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
void
beforeRoute(org.apache.camel.Exchange exchange, org.apache.camel.Route route)
void
beginTransactedBy(Object key)
boolean
containsSynchronization(org.apache.camel.spi.Synchronization synchronization)
org.apache.camel.spi.UnitOfWork
createChildUnitOfWork(org.apache.camel.Exchange childExchange)
void
done(org.apache.camel.Exchange exchange)
void
endTransactedBy(Object key)
org.apache.camel.Message
getOriginalInMessage()
org.apache.camel.Route
getRoute()
void
handoverSynchronization(org.apache.camel.Exchange target)
void
handoverSynchronization(org.apache.camel.Exchange target, Predicate<org.apache.camel.spi.Synchronization> filter)
boolean
isBeforeAfterProcess()
boolean
isTransacted()
boolean
isTransactedBy(Object key)
static void
onClassloaded(org.slf4j.Logger log)
boolean
onPrepare(org.apache.camel.Exchange exchange)
org.apache.camel.Route
popRoute()
void
pushRoute(org.apache.camel.Route route)
void
removeSynchronization(org.apache.camel.spi.Synchronization synchronization)
void
reset()
void
setParentUnitOfWork(org.apache.camel.spi.UnitOfWork parentUnitOfWork)
String
toString()
-
-
-
Constructor Detail
-
DefaultUnitOfWork
public DefaultUnitOfWork(org.apache.camel.Exchange exchange)
-
DefaultUnitOfWork
protected DefaultUnitOfWork(org.apache.camel.Exchange exchange, org.slf4j.Logger logger, org.apache.camel.spi.InflightRepository inflightRepository, boolean allowUseOriginalMessage, boolean useBreadcrumb)
-
DefaultUnitOfWork
public DefaultUnitOfWork(org.apache.camel.Exchange exchange, org.apache.camel.spi.InflightRepository inflightRepository, boolean allowUseOriginalMessage, boolean useBreadcrumb)
-
-
Method Detail
-
onClassloaded
public static void onClassloaded(org.slf4j.Logger log)
-
onPrepare
public boolean onPrepare(org.apache.camel.Exchange exchange)
- Specified by:
onPrepare
in interfaceorg.apache.camel.spi.UnitOfWork
-
reset
public void reset()
- Specified by:
reset
in interfaceorg.apache.camel.spi.UnitOfWork
-
setParentUnitOfWork
public void setParentUnitOfWork(org.apache.camel.spi.UnitOfWork parentUnitOfWork)
- Specified by:
setParentUnitOfWork
in interfaceorg.apache.camel.spi.UnitOfWork
-
createChildUnitOfWork
public org.apache.camel.spi.UnitOfWork createChildUnitOfWork(org.apache.camel.Exchange childExchange)
- Specified by:
createChildUnitOfWork
in interfaceorg.apache.camel.spi.UnitOfWork
-
addSynchronization
public void addSynchronization(org.apache.camel.spi.Synchronization synchronization)
- Specified by:
addSynchronization
in interfaceorg.apache.camel.spi.UnitOfWork
-
removeSynchronization
public void removeSynchronization(org.apache.camel.spi.Synchronization synchronization)
- Specified by:
removeSynchronization
in interfaceorg.apache.camel.spi.UnitOfWork
-
containsSynchronization
public boolean containsSynchronization(org.apache.camel.spi.Synchronization synchronization)
- Specified by:
containsSynchronization
in interfaceorg.apache.camel.spi.UnitOfWork
-
handoverSynchronization
public void handoverSynchronization(org.apache.camel.Exchange target)
- Specified by:
handoverSynchronization
in interfaceorg.apache.camel.spi.UnitOfWork
-
handoverSynchronization
public void handoverSynchronization(org.apache.camel.Exchange target, Predicate<org.apache.camel.spi.Synchronization> filter)
- Specified by:
handoverSynchronization
in interfaceorg.apache.camel.spi.UnitOfWork
-
done
public void done(org.apache.camel.Exchange exchange)
- Specified by:
done
in interfaceorg.apache.camel.spi.UnitOfWork
-
beforeRoute
public void beforeRoute(org.apache.camel.Exchange exchange, org.apache.camel.Route route)
- Specified by:
beforeRoute
in interfaceorg.apache.camel.spi.UnitOfWork
-
afterRoute
public void afterRoute(org.apache.camel.Exchange exchange, org.apache.camel.Route route)
- Specified by:
afterRoute
in interfaceorg.apache.camel.spi.UnitOfWork
-
getOriginalInMessage
public org.apache.camel.Message getOriginalInMessage()
- Specified by:
getOriginalInMessage
in interfaceorg.apache.camel.spi.UnitOfWork
-
isTransacted
public boolean isTransacted()
- Specified by:
isTransacted
in interfaceorg.apache.camel.spi.UnitOfWork
-
isTransactedBy
public boolean isTransactedBy(Object key)
- Specified by:
isTransactedBy
in interfaceorg.apache.camel.spi.UnitOfWork
-
beginTransactedBy
public void beginTransactedBy(Object key)
- Specified by:
beginTransactedBy
in interfaceorg.apache.camel.spi.UnitOfWork
-
endTransactedBy
public void endTransactedBy(Object key)
- Specified by:
endTransactedBy
in interfaceorg.apache.camel.spi.UnitOfWork
-
getRoute
public org.apache.camel.Route getRoute()
- Specified by:
getRoute
in interfaceorg.apache.camel.spi.UnitOfWork
-
pushRoute
public void pushRoute(org.apache.camel.Route route)
- Specified by:
pushRoute
in interfaceorg.apache.camel.spi.UnitOfWork
-
popRoute
public org.apache.camel.Route popRoute()
- Specified by:
popRoute
in interfaceorg.apache.camel.spi.UnitOfWork
-
isBeforeAfterProcess
public boolean isBeforeAfterProcess()
- Specified by:
isBeforeAfterProcess
in interfaceorg.apache.camel.spi.UnitOfWork
-
beforeProcess
public org.apache.camel.AsyncCallback beforeProcess(org.apache.camel.Processor processor, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
- Specified by:
beforeProcess
in interfaceorg.apache.camel.spi.UnitOfWork
-
afterProcess
public void afterProcess(org.apache.camel.Processor processor, org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback, boolean doneSync)
- Specified by:
afterProcess
in interfaceorg.apache.camel.spi.UnitOfWork
-
-