Class VmConsumer

  • All Implemented Interfaces:
    AutoCloseable, Runnable, org.apache.camel.CamelContextAware, 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.spi.ShutdownAware, org.apache.camel.spi.ShutdownPrepared, org.apache.camel.StatefulService, org.apache.camel.Suspendable, org.apache.camel.SuspendableService

    public class VmConsumer
    extends org.apache.camel.component.seda.SedaConsumer
    implements org.apache.camel.CamelContextAware
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • Constructor Summary

      Constructors 
      Constructor Description
      VmConsumer​(VmEndpoint endpoint, org.apache.camel.Processor processor)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.camel.CamelContext getCamelContext()  
      protected org.apache.camel.Exchange prepareExchange​(org.apache.camel.Exchange exchange)
      Strategy to prepare exchange for being processed by this consumer
      void setCamelContext​(org.apache.camel.CamelContext camelContext)  
      • Methods inherited from class org.apache.camel.component.seda.SedaConsumer

        deferShutdown, doResume, doRun, doShutdown, doStart, doStop, doSuspend, getEndpoint, getPendingExchangesSize, isRunAllowed, prepareShutdown, run, sendToConsumers
      • Methods inherited from class org.apache.camel.support.DefaultConsumer

        createExchange, createUoW, defaultConsumerCallback, doBuild, doInit, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, releaseExchange, setExceptionHandler, setRoute, setRouteId, toString
      • Methods inherited from class org.apache.camel.support.service.BaseService

        build, doFail, doLifecycleChange, fail, getStatus, init, isBuild, isInit, isNew, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
      • Methods inherited from interface org.apache.camel.Service

        build, close, init, start, stop
      • Methods inherited from interface org.apache.camel.ShutdownableService

        shutdown
      • Methods inherited from interface org.apache.camel.StatefulService

        getStatus, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        isSuspended, resume, suspend
    • Constructor Detail

      • VmConsumer

        public VmConsumer​(VmEndpoint endpoint,
                          org.apache.camel.Processor processor)
    • Method Detail

      • getCamelContext

        public org.apache.camel.CamelContext getCamelContext()
        Specified by:
        getCamelContext in interface org.apache.camel.CamelContextAware
      • setCamelContext

        public void setCamelContext​(org.apache.camel.CamelContext camelContext)
        Specified by:
        setCamelContext in interface org.apache.camel.CamelContextAware
      • prepareExchange

        protected org.apache.camel.Exchange prepareExchange​(org.apache.camel.Exchange exchange)
        Strategy to prepare exchange for being processed by this consumer
        Overrides:
        prepareExchange in class org.apache.camel.component.seda.SedaConsumer
        Parameters:
        exchange - the exchange
        Returns:
        the exchange to process by this consumer.