Class MllpConsumer

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.Consumer, org.apache.camel.EndpointAware, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.RouteIdAware, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

    public class MllpConsumer
    extends org.apache.camel.support.DefaultConsumer
    MllpConsumer wraps a MinaConsumer for having a hook to shutdown some Mina resources when the consumer is closing
    • Method Detail

      • start

        public void start()
        Specified by:
        start in interface org.apache.camel.Service
        Overrides:
        start in class org.apache.camel.support.service.BaseService
      • getProcessor

        public org.apache.camel.Processor getProcessor()
        Specified by:
        getProcessor in interface org.apache.camel.Consumer
        Overrides:
        getProcessor in class org.apache.camel.support.DefaultConsumer
      • getAsyncProcessor

        public org.apache.camel.AsyncProcessor getAsyncProcessor()
        Overrides:
        getAsyncProcessor in class org.apache.camel.support.DefaultConsumer
      • isSuspendingOrSuspended

        public boolean isSuspendingOrSuspended()
        Overrides:
        isSuspendingOrSuspended in class org.apache.camel.support.service.BaseService
      • getAcceptor

        public org.apache.mina.core.service.IoAcceptor getAcceptor()
      • isSuspending

        public boolean isSuspending()
        Specified by:
        isSuspending in interface org.apache.camel.StatefulService
        Overrides:
        isSuspending in class org.apache.camel.support.service.BaseService
      • isStoppingOrStopped

        public boolean isStoppingOrStopped()
        Overrides:
        isStoppingOrStopped in class org.apache.camel.support.service.BaseService
      • isStopping

        public boolean isStopping()
        Specified by:
        isStopping in interface org.apache.camel.StatefulService
        Overrides:
        isStopping in class org.apache.camel.support.service.BaseService
      • getRoute

        public org.apache.camel.Route getRoute()
        Specified by:
        getRoute in interface org.apache.camel.RouteAware
        Overrides:
        getRoute in class org.apache.camel.support.DefaultConsumer
      • setRoute

        public void setRoute​(org.apache.camel.Route route)
        Specified by:
        setRoute in interface org.apache.camel.RouteAware
        Overrides:
        setRoute in class org.apache.camel.support.DefaultConsumer
      • setExceptionHandler

        public void setExceptionHandler​(org.apache.camel.spi.ExceptionHandler exceptionHandler)
        Overrides:
        setExceptionHandler in class org.apache.camel.support.DefaultConsumer
      • isStopped

        public boolean isStopped()
        Specified by:
        isStopped in interface org.apache.camel.StatefulService
        Overrides:
        isStopped in class org.apache.camel.support.service.BaseService
      • isStarting

        public boolean isStarting()
        Specified by:
        isStarting in interface org.apache.camel.StatefulService
        Overrides:
        isStarting in class org.apache.camel.support.service.BaseService
      • isRunAllowed

        public boolean isRunAllowed()
        Specified by:
        isRunAllowed in interface org.apache.camel.StatefulService
        Overrides:
        isRunAllowed in class org.apache.camel.support.service.BaseService
      • setAcceptor

        public void setAcceptor​(org.apache.mina.core.service.IoAcceptor acceptor)
      • shutdown

        public void shutdown()
        Specified by:
        shutdown in interface org.apache.camel.ShutdownableService
        Overrides:
        shutdown in class org.apache.camel.support.service.BaseService
      • createUoW

        public org.apache.camel.spi.UnitOfWork createUoW​(org.apache.camel.Exchange exchange)
                                                  throws Exception
        Overrides:
        createUoW in class org.apache.camel.support.DefaultConsumer
        Throws:
        Exception
      • getStatus

        public org.apache.camel.ServiceStatus getStatus()
        Specified by:
        getStatus in interface org.apache.camel.StatefulService
        Overrides:
        getStatus in class org.apache.camel.support.service.BaseService
      • resume

        public void resume()
        Specified by:
        resume in interface org.apache.camel.SuspendableService
        Overrides:
        resume in class org.apache.camel.support.service.BaseService
      • getExceptionHandler

        public org.apache.camel.spi.ExceptionHandler getExceptionHandler()
        Overrides:
        getExceptionHandler in class org.apache.camel.support.DefaultConsumer
      • isSuspended

        public boolean isSuspended()
        Specified by:
        isSuspended in interface org.apache.camel.SuspendableService
        Overrides:
        isSuspended in class org.apache.camel.support.service.BaseService
      • isStarted

        public boolean isStarted()
        Specified by:
        isStarted in interface org.apache.camel.StatefulService
        Overrides:
        isStarted in class org.apache.camel.support.service.BaseService
      • getEndpoint

        public org.apache.camel.component.mina.MinaEndpoint getEndpoint()
        Specified by:
        getEndpoint in interface org.apache.camel.EndpointAware
        Overrides:
        getEndpoint in class org.apache.camel.support.DefaultConsumer
      • doneUoW

        public void doneUoW​(org.apache.camel.Exchange exchange)
        Overrides:
        doneUoW in class org.apache.camel.support.DefaultConsumer
      • suspend

        public void suspend()
        Specified by:
        suspend in interface org.apache.camel.SuspendableService
        Overrides:
        suspend in class org.apache.camel.support.service.BaseService
      • stop

        public void stop()
        Specified by:
        stop in interface org.apache.camel.Service
        Overrides:
        stop in class org.apache.camel.support.service.BaseService
      • doStop

        protected void doStop()
                       throws Exception
        Overrides:
        doStop in class org.apache.camel.support.DefaultConsumer
        Throws:
        Exception