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, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, 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