public class BeanstalkComponent
extends org.apache.camel.impl.UriEndpointComponent
beanstalk://[host[:port]][/tube]?query
Parameters:command
- one of "put", "release", "bury", "touch", "delete", "kick".
"put" is the default for Producers.jobPriority
jobDelay
jobTimeToRun
consumer.onFailure
consumer.awaitJob
BeanstalkEndpoint
,
ConnectionSettingsFactory
Modifier and Type | Field and Description |
---|---|
static String |
COMMAND_BURY |
static String |
COMMAND_DELETE |
static String |
COMMAND_KICK |
static String |
COMMAND_PUT |
static String |
COMMAND_RELEASE |
static String |
COMMAND_TOUCH |
static int |
DEFAULT_DELAY |
static long |
DEFAULT_PRIORITY |
static int |
DEFAULT_TIME_TO_RUN |
static String |
DEFAULT_TUBE |
Constructor and Description |
---|
BeanstalkComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
static ConnectionSettingsFactory |
getConnectionSettingsFactory() |
static void |
setConnectionSettingsFactory(ConnectionSettingsFactory connFactory)
Custom
ConnectionSettingsFactory . |
boolean |
useRawUri() |
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, validateParameters, validateURI
public static final String DEFAULT_TUBE
public static final String COMMAND_BURY
public static final String COMMAND_RELEASE
public static final String COMMAND_PUT
public static final String COMMAND_TOUCH
public static final String COMMAND_DELETE
public static final String COMMAND_KICK
public static final long DEFAULT_PRIORITY
public static final int DEFAULT_DELAY
public static final int DEFAULT_TIME_TO_RUN
public boolean useRawUri()
useRawUri
in interface org.apache.camel.Component
useRawUri
in class org.apache.camel.impl.DefaultComponent
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public static void setConnectionSettingsFactory(ConnectionSettingsFactory connFactory)
ConnectionSettingsFactory
.
Specify which ConnectionSettingsFactory
to use to make connections to Beanstalkd. Especially
useful for unit testing without beanstalkd daemon (you can mock ConnectionSettings
)connFactory
- the connection factoryConnectionSettingsFactory
public static ConnectionSettingsFactory getConnectionSettingsFactory()
Apache Camel