@UriEndpoint(firstVersion="2.15.0", scheme="beanstalk", title="Beanstalk", syntax="beanstalk:connectionSettings", consumerClass=BeanstalkConsumer.class, label="messaging") public class BeanstalkEndpoint extends org.apache.camel.impl.ScheduledPollEndpoint implements org.apache.camel.AsyncEndpoint
Constructor and Description |
---|
BeanstalkEndpoint(String uri,
org.apache.camel.Component component,
ConnectionSettings conn,
String connectionSettings) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer()
Creates Camel producer.
|
BeanstalkCommand |
getCommand() |
ConnectionSettings |
getConn() |
ConnectionSettings |
getConnection() |
String |
getConnectionSettings() |
int |
getJobDelay() |
long |
getJobPriority() |
int |
getJobTimeToRun() |
BeanstalkCommand |
getOnFailure() |
boolean |
isAwaitJob() |
boolean |
isSingleton() |
boolean |
isUseBlockIO() |
void |
setAwaitJob(boolean awaitJob)
Whether to wait for job to complete before ack the job from beanstalk
|
void |
setCommand(BeanstalkCommand command)
put means to put the job into Beanstalk.
|
void |
setJobDelay(int jobDelay)
Job delay in seconds.
|
void |
setJobPriority(long jobPriority)
Job priority.
|
void |
setJobTimeToRun(int jobTimeToRun)
Job time to run in seconds.
|
void |
setOnFailure(BeanstalkCommand onFailure)
Command to use when processing failed.
|
void |
setUseBlockIO(boolean useBlockIO)
Whether to use blockIO.
|
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public BeanstalkEndpoint(String uri, org.apache.camel.Component component, ConnectionSettings conn, String connectionSettings)
public String getConnectionSettings()
public ConnectionSettings getConnection()
public ConnectionSettings getConn()
public BeanstalkCommand getCommand()
public void setCommand(BeanstalkCommand command)
public long getJobPriority()
public void setJobPriority(long jobPriority)
public int getJobDelay()
public void setJobDelay(int jobDelay)
public int getJobTimeToRun()
public void setJobTimeToRun(int jobTimeToRun)
public BeanstalkCommand getOnFailure()
public void setOnFailure(BeanstalkCommand onFailure)
public boolean isUseBlockIO()
public void setUseBlockIO(boolean useBlockIO)
public boolean isAwaitJob()
public void setAwaitJob(boolean awaitJob)
public org.apache.camel.Producer createProducer() throws Exception
BeanstalkComponent
URI) it
will create one of the producer implementations.createProducer
in interface org.apache.camel.Endpoint
Producer
instanceIllegalArgumentException
- when ConnectionSettings
cannot
create a writable Client
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
Apache Camel