Class BeanstalkConsumer

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

    public class BeanstalkConsumer
    extends org.apache.camel.support.ScheduledPollConsumer
    PollingConsumer to read Beanstalk jobs.

    The consumer may delete the job immediately or based on successful Exchange completion. The behavior is configurable by consumer.awaitJob flag (by default true)

    This consumer will add a Synchronization object to every Exchange object it creates in order to react on successful exchange completion or failure.

    In the case of successful completion, Beanstalk's delete method is called upon the job. In the case of failure the default reaction is to call bury.

    The reaction on failures is configurable: possible variants are "bury", "release" or "delete"

    • 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void doStart()  
      protected void doStop()  
      BeanstalkEndpoint getEndpoint()  
      BeanstalkCommand getOnFailure()  
      boolean isAwaitJob()  
      boolean isUseBlockIO()  
      protected int poll()  
      protected void resetClient()  
      void setAwaitJob​(boolean awaitJob)  
      void setOnFailure​(BeanstalkCommand onFailure)  
      void setUseBlockIO​(boolean useBlockIO)  
      • Methods inherited from class org.apache.camel.support.ScheduledPollConsumer

        afterPoll, beforePoll, doInit, doShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRepeatCount, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRepeatCount, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
      • Methods inherited from class org.apache.camel.support.DefaultConsumer

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

        build, doBuild, doFail, doLifecycleChange, doResume, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, 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, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        isSuspended, resume, suspend
    • Constructor Detail

      • BeanstalkConsumer

        public BeanstalkConsumer​(BeanstalkEndpoint endpoint,
                                 org.apache.camel.Processor processor)
    • Method Detail

      • poll

        protected int poll()
                    throws Exception
        Specified by:
        poll in class org.apache.camel.support.ScheduledPollConsumer
        Throws:
        Exception
      • isUseBlockIO

        public boolean isUseBlockIO()
      • setUseBlockIO

        public void setUseBlockIO​(boolean useBlockIO)
      • isAwaitJob

        public boolean isAwaitJob()
      • setAwaitJob

        public void setAwaitJob​(boolean awaitJob)
      • getEndpoint

        public BeanstalkEndpoint getEndpoint()
        Specified by:
        getEndpoint in interface org.apache.camel.EndpointAware
        Overrides:
        getEndpoint in class org.apache.camel.support.DefaultConsumer
      • doStart

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

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

        protected void resetClient()