public class AMQPComponent
extends org.apache.camel.component.jms.JmsComponent
Constructor and Description |
---|
AMQPComponent() |
AMQPComponent(org.apache.camel.CamelContext context) |
AMQPComponent(javax.jms.ConnectionFactory connectionFactory) |
AMQPComponent(org.apache.camel.component.jms.JmsConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
static AMQPComponent |
amqp10Component(String uri)
Deprecated.
|
static AMQPComponent |
amqpComponent(String uri) |
static AMQPComponent |
amqpComponent(String uri,
String username,
String password) |
protected org.apache.camel.component.jms.JmsConfiguration |
createConfiguration()
Factory method to create the default configuration instance
|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected void |
doStart() |
void |
setIncludeAmqpAnnotations(boolean includeAmqpAnnotations)
Whether to include AMQP annotations when mapping from AMQP to Camel Message.
|
convertPathToActualDestination, createQueueEndpoint, createTemporaryQueueEndpoint, createTemporaryTopicEndpoint, createTopicEndpoint, doShutdown, getAsyncStartStopExecutorService, getConfiguration, getConnectionFactory, getMessageCreatedStrategy, getQueueBrowseStrategy, getSubscriptionName, getWaitForProvisionCorrelationToBeUpdatedCounter, getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime, isAllowAutoWiredConnectionFactory, isAllowAutoWiredDestinationResolver, isArtemisStreamingEnabled, isFormatDateHeadersToIso8601, isStreamMessageTypeEnabled, isSubscriptionDurable, isSubscriptionShared, jmsComponent, jmsComponent, jmsComponent, jmsComponentAutoAcknowledge, jmsComponentClientAcknowledge, jmsComponentTransacted, jmsComponentTransacted, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAllowAdditionalHeaders, setAllowNullBody, setAllowReplyManagerQuickStop, setAlwaysCopyMessage, setApplicationContext, setArtemisStreamingEnabled, setAsyncConsumer, setAsyncStartListener, setAsyncStopListener, setAutoStartup, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConfiguration, 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, setPassword, 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, doStop, 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 AMQPComponent()
public AMQPComponent(org.apache.camel.component.jms.JmsConfiguration configuration)
public AMQPComponent(org.apache.camel.CamelContext context)
public AMQPComponent(javax.jms.ConnectionFactory connectionFactory)
@Deprecated public static AMQPComponent amqp10Component(String uri) throws MalformedURLException
amqpComponent(String uri)
instead.MalformedURLException
public static AMQPComponent amqpComponent(String uri)
public static AMQPComponent amqpComponent(String uri, String username, String password)
protected void doStart() throws Exception
doStart
in class org.apache.camel.component.jms.JmsComponent
Exception
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.component.jms.JmsComponent
Exception
protected org.apache.camel.component.jms.JmsConfiguration createConfiguration()
createConfiguration
in class org.apache.camel.component.jms.JmsComponent
public void setIncludeAmqpAnnotations(boolean includeAmqpAnnotations)
Apache Camel