Class CamelInternalProcessor.UnitOfWorkProcessorAdvice

  • All Implemented Interfaces:
    org.apache.camel.spi.CamelInternalProcessorAdvice<org.apache.camel.spi.UnitOfWork>
    Direct Known Subclasses:
    CamelInternalProcessor.ChildUnitOfWorkProcessorAdvice
    Enclosing class:
    CamelInternalProcessor

    public static class CamelInternalProcessor.UnitOfWorkProcessorAdvice
    extends Object
    implements org.apache.camel.spi.CamelInternalProcessorAdvice<org.apache.camel.spi.UnitOfWork>
    Advice to inject new UnitOfWork to the Exchange if needed, and as well to ensure the UnitOfWork is done and stopped.
    • Constructor Detail

      • UnitOfWorkProcessorAdvice

        public UnitOfWorkProcessorAdvice​(org.apache.camel.Route route,
                                         org.apache.camel.CamelContext camelContext)
    • Method Detail

      • before

        public org.apache.camel.spi.UnitOfWork before​(org.apache.camel.Exchange exchange)
                                               throws Exception
        Specified by:
        before in interface org.apache.camel.spi.CamelInternalProcessorAdvice<org.apache.camel.spi.UnitOfWork>
        Throws:
        Exception
      • after

        public void after​(org.apache.camel.Exchange exchange,
                          org.apache.camel.spi.UnitOfWork uow)
                   throws Exception
        Specified by:
        after in interface org.apache.camel.spi.CamelInternalProcessorAdvice<org.apache.camel.spi.UnitOfWork>
        Throws:
        Exception
      • createUnitOfWork

        protected org.apache.camel.spi.UnitOfWork createUnitOfWork​(org.apache.camel.Exchange exchange)