public class BeanstalkComponent extends 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 |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
BeanstalkComponent() |
Modifier and Type | Method and Description |
---|---|
protected Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters)
A factory method allowing derived components to create a new endpoint
from the given URI, remaining path and optional parameters
|
static ConnectionSettingsFactory |
getConnectionSettingsFactory() |
static void |
setConnectionSettingsFactory(ConnectionSettingsFactory connFactory)
Custom
ConnectionSettingsFactory . |
boolean |
useRawUri()
Whether to use raw or encoded uri, when creating endpoints.
|
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
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
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()
Component
useRawUri
in interface Component
useRawUri
in class DefaultComponent
protected Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
DefaultComponent
createEndpoint
in class DefaultComponent
uri
- the full URI of the endpointremaining
- the remaining part of the URI without the query
parameters or component prefixparameters
- the optional parameters passed inException
- is thrown if error creating the endpointpublic 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()
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.