Class 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 of UnitOfWork
    • 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 interface org.apache.camel.spi.UnitOfWork
      • reset

        public void reset()
        Specified by:
        reset in interface org.apache.camel.spi.UnitOfWork
      • setParentUnitOfWork

        public void setParentUnitOfWork​(org.apache.camel.spi.UnitOfWork parentUnitOfWork)
        Specified by:
        setParentUnitOfWork in interface org.apache.camel.spi.UnitOfWork
      • createChildUnitOfWork

        public org.apache.camel.spi.UnitOfWork createChildUnitOfWork​(org.apache.camel.Exchange childExchange)
        Specified by:
        createChildUnitOfWork in interface org.apache.camel.spi.UnitOfWork
      • addSynchronization

        public void addSynchronization​(org.apache.camel.spi.Synchronization synchronization)
        Specified by:
        addSynchronization in interface org.apache.camel.spi.UnitOfWork
      • removeSynchronization

        public void removeSynchronization​(org.apache.camel.spi.Synchronization synchronization)
        Specified by:
        removeSynchronization in interface org.apache.camel.spi.UnitOfWork
      • containsSynchronization

        public boolean containsSynchronization​(org.apache.camel.spi.Synchronization synchronization)
        Specified by:
        containsSynchronization in interface org.apache.camel.spi.UnitOfWork
      • handoverSynchronization

        public void handoverSynchronization​(org.apache.camel.Exchange target)
        Specified by:
        handoverSynchronization in interface org.apache.camel.spi.UnitOfWork
      • handoverSynchronization

        public void handoverSynchronization​(org.apache.camel.Exchange target,
                                            Predicate<org.apache.camel.spi.Synchronization> filter)
        Specified by:
        handoverSynchronization in interface org.apache.camel.spi.UnitOfWork
      • done

        public void done​(org.apache.camel.Exchange exchange)
        Specified by:
        done in interface org.apache.camel.spi.UnitOfWork
      • beforeRoute

        public void beforeRoute​(org.apache.camel.Exchange exchange,
                                org.apache.camel.Route route)
        Specified by:
        beforeRoute in interface org.apache.camel.spi.UnitOfWork
      • afterRoute

        public void afterRoute​(org.apache.camel.Exchange exchange,
                               org.apache.camel.Route route)
        Specified by:
        afterRoute in interface org.apache.camel.spi.UnitOfWork
      • getOriginalInMessage

        public org.apache.camel.Message getOriginalInMessage()
        Specified by:
        getOriginalInMessage in interface org.apache.camel.spi.UnitOfWork
      • isTransacted

        public boolean isTransacted()
        Specified by:
        isTransacted in interface org.apache.camel.spi.UnitOfWork
      • isTransactedBy

        public boolean isTransactedBy​(Object key)
        Specified by:
        isTransactedBy in interface org.apache.camel.spi.UnitOfWork
      • beginTransactedBy

        public void beginTransactedBy​(Object key)
        Specified by:
        beginTransactedBy in interface org.apache.camel.spi.UnitOfWork
      • endTransactedBy

        public void endTransactedBy​(Object key)
        Specified by:
        endTransactedBy in interface org.apache.camel.spi.UnitOfWork
      • getRoute

        public org.apache.camel.Route getRoute()
        Specified by:
        getRoute in interface org.apache.camel.spi.UnitOfWork
      • pushRoute

        public void pushRoute​(org.apache.camel.Route route)
        Specified by:
        pushRoute in interface org.apache.camel.spi.UnitOfWork
      • popRoute

        public org.apache.camel.Route popRoute()
        Specified by:
        popRoute in interface org.apache.camel.spi.UnitOfWork
      • isBeforeAfterProcess

        public boolean isBeforeAfterProcess()
        Specified by:
        isBeforeAfterProcess in interface org.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 interface org.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 interface org.apache.camel.spi.UnitOfWork