public class ActiveMQComponent
extends org.apache.camel.component.jms.JmsComponent
implements org.apache.camel.spi.EndpointCompleter
Constructor and Description |
---|
ActiveMQComponent() |
ActiveMQComponent(ActiveMQConfiguration configuration) |
ActiveMQComponent(org.apache.camel.CamelContext context) |
Modifier and Type | Method and Description |
---|---|
static ActiveMQComponent |
activeMQComponent()
Creates an ActiveMQ Component
|
static ActiveMQComponent |
activeMQComponent(String brokerURL)
Creates an ActiveMQ Component
connecting to the given broker URL
|
protected void |
addPooledConnectionFactoryService(org.apache.activemq.Service pooledConnectionFactoryService) |
protected void |
addSingleConnectionFactory(org.springframework.jms.connection.SingleConnectionFactory singleConnectionFactory) |
List<String> |
completeEndpointPath(org.apache.camel.ComponentConfiguration componentConfiguration,
String completionText) |
protected String |
convertPathToActualDestination(String path,
Map<String,Object> parameters) |
protected org.apache.camel.component.jms.JmsConfiguration |
createConfiguration() |
protected void |
createDestinationSource() |
protected void |
doStart() |
protected void |
doStop() |
boolean |
getAllowAutoWiredConnectionFactory()
We don't want to ever auto-wire the connection factory from the spring app context.
|
boolean |
isExposeAllQueues() |
void |
setBrokerURL(String brokerURL) |
void |
setConfiguration(org.apache.camel.component.jms.JmsConfiguration configuration) |
void |
setExposeAllQueues(boolean exposeAllQueues)
If enabled this will cause all Queues in the ActiveMQ broker to be eagerly populated into the CamelContext
so that they can be easily browsed by any Camel tooling.
|
void |
setPassword(String password) |
void |
setUsePooledConnection(boolean usePooledConnection) |
void |
setUserName(String userName) |
void |
setUseSingleConnection(boolean useSingleConnection) |
createEndpoint, createQueueEndpoint, createTemporaryQueueEndpoint, createTemporaryTopicEndpoint, createTopicEndpoint, doShutdown, getAsyncStartStopExecutorService, getConfiguration, getConnectionFactory, getMessageCreatedStrategy, getQueueBrowseStrategy, getSubscriptionName, getWaitForProvisionCorrelationToBeUpdatedCounter, getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime, isAllowAutoWiredConnectionFactory, isAllowAutoWiredDestinationResolver, isFormatDateHeadersToIso8601, isStreamMessageTypeEnabled, isSubscriptionDurable, isSubscriptionShared, jmsComponent, jmsComponent, jmsComponent, jmsComponentAutoAcknowledge, jmsComponentClientAcknowledge, jmsComponentTransacted, jmsComponentTransacted, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAllowAdditionalHeaders, setAllowNullBody, setAllowReplyManagerQuickStop, setAlwaysCopyMessage, setApplicationContext, setAsyncConsumer, setAsyncStartListener, setAsyncStopListener, setAutoStartup, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConnectionFactory, setCorrelationProperty, setDefaultTaskExecutorType, setDeliveryMode, setDeliveryPersistent, setDestinationResolver, setDurableSubscriptionName, setEagerLoadingOfProperties, setErrorHandler, setErrorHandlerLoggingLevel, setErrorHandlerLogStackTrace, setExceptionListener, setExplicitQosEnabled, setExposeListenerSession, setForceSendOriginalMessage, setFormatDateHeadersToIso8601, setIdleConsumerLimit, setIdleTaskExecutionLimit, setIncludeAllJMSXProperties, setIncludeSentJMSMessageID, setJmsKeyFormatStrategy, setJmsKeyFormatStrategy, setJmsOperations, setLazyCreateTransactionManager, setMapJmsMessage, setMaxConcurrentConsumers, setMaxMessagesPerTask, setMessageConverter, setMessageCreatedStrategy, setMessageIdEnabled, setMessageTimestampEnabled, setPreserveMessageQos, setPriority, setPubSubNoLocal, setQueueBrowseStrategy, setReceiveTimeout, setRecoveryInterval, setReplyOnTimeoutToMaxConcurrentConsumers, setReplyToCacheLevelName, setReplyToConcurrentConsumers, setReplyToMaxConcurrentConsumers, setReplyToType, setRequestTimeout, setRequestTimeoutCheckerInterval, setStreamMessageTypeEnabled, setSubscriptionDurable, setSubscriptionName, setSubscriptionShared, setTaskExecutor, setTestConnectionOnStartup, setTimeToLive, setTransacted, setTransactionManager, setTransactionName, setTransactionTimeout, setTransferException, setTransferExchange, setTransferFault, setUseMessageIDAsCorrelationID, setUsername, setWaitForProvisionCorrelationToBeUpdatedCounter, setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime
getHeaderFilterStrategy, setEndpointHeaderFilterStrategy, setHeaderFilterStrategy
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public ActiveMQComponent()
public ActiveMQComponent(org.apache.camel.CamelContext context)
public ActiveMQComponent(ActiveMQConfiguration configuration)
public static ActiveMQComponent activeMQComponent()
public static ActiveMQComponent activeMQComponent(String brokerURL)
brokerURL
- the URL to connect topublic void setBrokerURL(String brokerURL)
public void setUserName(String userName)
public void setPassword(String password)
setPassword
in class org.apache.camel.component.jms.JmsComponent
public boolean isExposeAllQueues()
public void setExposeAllQueues(boolean exposeAllQueues)
exposeAllQueues
- public void setUsePooledConnection(boolean usePooledConnection)
public void setUseSingleConnection(boolean useSingleConnection)
protected void addPooledConnectionFactoryService(org.apache.activemq.Service pooledConnectionFactoryService)
protected void addSingleConnectionFactory(org.springframework.jms.connection.SingleConnectionFactory singleConnectionFactory)
protected String convertPathToActualDestination(String path, Map<String,Object> parameters)
convertPathToActualDestination
in class org.apache.camel.component.jms.JmsComponent
protected void doStart() throws Exception
doStart
in class org.apache.camel.component.jms.JmsComponent
Exception
protected void createDestinationSource()
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
public void setConfiguration(org.apache.camel.component.jms.JmsConfiguration configuration)
setConfiguration
in class org.apache.camel.component.jms.JmsComponent
protected org.apache.camel.component.jms.JmsConfiguration createConfiguration()
createConfiguration
in class org.apache.camel.component.jms.JmsComponent
public List<String> completeEndpointPath(org.apache.camel.ComponentConfiguration componentConfiguration, String completionText)
completeEndpointPath
in interface org.apache.camel.spi.EndpointCompleter
public boolean getAllowAutoWiredConnectionFactory()
Apache Camel