Package org.apache.camel.component.jms
Class JmsEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.jms.JmsEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.AsyncEndpoint
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.MultipleConsumersSupport
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.spi.HeaderFilterStrategyAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
- Direct Known Subclasses:
JmsQueueEndpoint
,JmsTemporaryTopicEndpoint
@ManagedResource(description="Managed JMS Endpoint") @UriEndpoint(firstVersion="1.0.0", scheme="jms", title="JMS", syntax="jms:destinationType:destinationName", category=MESSAGING) @Metadata(excludeProperties="bridgeErrorHandler") public class JmsEndpoint extends org.apache.camel.support.DefaultEndpoint implements org.apache.camel.AsyncEndpoint, org.apache.camel.spi.HeaderFilterStrategyAware, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service
Sent and receive messages to/from a JMS Queue or Topic. This component uses Spring JMS and supports JMS 1.1 and 2.0 API.
-
-
Constructor Summary
Constructors Constructor Description JmsEndpoint()
JmsEndpoint(String endpointUri, String destinationName)
Creates a pub-sub endpoint with the given destinationJmsEndpoint(String endpointUri, String destinationName, boolean pubSubDomain)
JmsEndpoint(String endpointUri, JmsBinding binding, JmsConfiguration configuration, String destinationName, boolean pubSubDomain)
JmsEndpoint(String uri, JmsComponent component, String destinationName, boolean pubSubDomain, JmsConfiguration configuration)
JmsEndpoint(javax.jms.Topic destination)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configureListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer, JmsConsumer consumer)
protected JmsBinding
createBinding()
Creates theJmsBinding
to use.JmsConsumer
createConsumer(org.apache.camel.Processor processor)
JmsConsumer
createConsumer(org.apache.camel.Processor processor, org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
Creates a consumer using the given processor and listener containerprotected String
createEndpointUri()
org.apache.camel.Exchange
createExchange(javax.jms.Message message, javax.jms.Session session)
org.apache.camel.Exchange
createExchange(org.apache.camel.ExchangePattern pattern)
org.springframework.jms.core.JmsOperations
createInOnlyTemplate()
Factory method for creating a new template for InOnly message exchangesorg.springframework.jms.core.JmsOperations
createInOutTemplate()
Factory method for creating a new template for InOut message exchangesorg.springframework.jms.listener.AbstractMessageListenerContainer
createMessageListenerContainer()
org.apache.camel.PollingConsumer
createPollingConsumer()
org.apache.camel.Producer
createProducer()
int
getAcknowledgementMode()
String
getAcknowledgementModeName()
String
getAllowAdditionalHeaders()
protected ExecutorService
getAsyncStartStopExecutorService()
JmsBinding
getBinding()
int
getCacheLevel()
String
getCacheLevelName()
String
getClientId()
JmsComponent
getComponent()
int
getConcurrentConsumers()
JmsConfiguration
getConfiguration()
javax.jms.ConnectionFactory
getConnectionFactory()
DefaultTaskExecutorType
getDefaultTaskExecutorType()
Integer
getDeliveryMode()
javax.jms.Destination
getDestination()
String
getDestinationName()
org.springframework.jms.support.destination.DestinationResolver
getDestinationResolver()
String
getDestinationType()
String
getDurableSubscriptionName()
String
getEagerPoisonBody()
String
getEndpointConfiguredDestinationName()
Gets the destination name which was configured from the endpoint uri.org.springframework.util.ErrorHandler
getErrorHandler()
org.apache.camel.LoggingLevel
getErrorHandlerLoggingLevel()
javax.jms.ExceptionListener
getExceptionListener()
org.apache.camel.spi.HeaderFilterStrategy
getHeaderFilterStrategy()
int
getIdleConsumerLimit()
int
getIdleTaskExecutionLimit()
JmsKeyFormatStrategy
getJmsKeyFormatStrategy()
JmsMessageType
getJmsMessageType()
org.springframework.jms.core.JmsOperations
getJmsOperations()
javax.jms.ConnectionFactory
getListenerConnectionFactory()
int
getMaxConcurrentConsumers()
int
getMaxMessagesPerTask()
org.springframework.jms.support.converter.MessageConverter
getMessageConverter()
MessageCreatedStrategy
getMessageCreatedStrategy()
MessageListenerContainerFactory
getMessageListenerContainerFactory()
int
getPriority()
long
getReceiveTimeout()
long
getRecoveryInterval()
String
getReplyTo()
String
getReplyToCacheLevelName()
int
getReplyToConcurrentConsumers()
String
getReplyToDestinationSelectorName()
int
getReplyToMaxConcurrentConsumers()
int
getReplyToOnTimeoutMaxConcurrentConsumers()
String
getReplyToOverride()
String
getReplyToType()
long
getRequestTimeout()
long
getRequestTimeoutCheckerInterval()
int
getRunningMessageListeners()
String
getSelector()
String
getSubscriptionName()
org.springframework.core.task.TaskExecutor
getTaskExecutor()
javax.jms.ConnectionFactory
getTemplateConnectionFactory()
String
getThreadName()
long
getTimeToLive()
org.springframework.transaction.PlatformTransactionManager
getTransactionManager()
String
getTransactionName()
int
getTransactionTimeout()
int
getWaitForProvisionCorrelationToBeUpdatedCounter()
long
getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime()
boolean
isAcceptMessagesWhileStopping()
boolean
isAllowNullBody()
boolean
isAllowReplyManagerQuickStop()
boolean
isAllowSerializedHeaders()
boolean
isAlwaysCopyMessage()
boolean
isArtemisStreamingEnabled()
boolean
isAsyncConsumer()
boolean
isAsyncStartListener()
boolean
isAsyncStopListener()
boolean
isAutoStartup()
boolean
isDeliveryPersistent()
boolean
isDisableReplyTo()
boolean
isDisableTimeToLive()
boolean
isEagerLoadingOfProperties()
boolean
isErrorHandlerLogStackTrace()
boolean
isExplicitQosEnabled()
boolean
isExposeListenerSession()
boolean
isForceSendOriginalMessage()
boolean
isFormatDateHeadersToIso8601()
boolean
isIncludeAllJMSXProperties()
boolean
isIncludeSentJMSMessageID()
boolean
isLazyCreateTransactionManager()
boolean
isMessageIdEnabled()
boolean
isMessageTimestampEnabled()
boolean
isMultipleConsumersSupported()
boolean
isPreserveMessageQos()
boolean
isPubSubDomain()
boolean
isPubSubNoLocal()
boolean
isReplyToDeliveryPersistent()
boolean
isReplyToSameDestinationAllowed()
protected boolean
isRunning()
State whether this endpoint is running (eg started)boolean
isSubscriptionDurable()
boolean
isSubscriptionShared()
boolean
isTestConnectionOnStartup()
boolean
isTransacted()
boolean
isTransactedInOut()
boolean
isTransferException()
boolean
isTransferExchange()
boolean
isUseMessageIDAsCorrelationID()
static JmsEndpoint
newInstance(javax.jms.Destination destination)
Returns a new JMS endpoint for the given JMS destinationstatic JmsEndpoint
newInstance(javax.jms.Destination destination, JmsComponent component)
Returns a new JMS endpoint for the given JMS destination using the configuration from the given JMS componentvoid
onListenerContainerStarting(org.springframework.jms.listener.AbstractMessageListenerContainer container)
void
onListenerContainerStopped(org.springframework.jms.listener.AbstractMessageListenerContainer container)
void
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
void
setAcknowledgementMode(int consumerAcknowledgementMode)
void
setAcknowledgementModeName(String consumerAcknowledgementMode)
void
setAllowAdditionalHeaders(String allowAdditionalHeaders)
void
setAllowNullBody(boolean allowNullBody)
void
setAllowReplyManagerQuickStop(boolean allowReplyManagerQuickStop)
void
setAllowSerializedHeaders(boolean allowSerializedHeaders)
void
setAlwaysCopyMessage(boolean alwaysCopyMessage)
void
setArtemisStreamingEnabled(boolean artemisStreamingEnabled)
void
setAsyncConsumer(boolean asyncConsumer)
void
setAsyncStartListener(boolean asyncStartListener)
void
setAsyncStopListener(boolean asyncStopListener)
void
setAutoStartup(boolean autoStartup)
void
setBinding(JmsBinding binding)
Sets the binding used to convert from a Camel message to and from a JMS messagevoid
setCacheLevel(int cacheLevel)
void
setCacheLevelName(String cacheName)
void
setClientId(String consumerClientId)
void
setConcurrentConsumers(int concurrentConsumers)
void
setConfiguration(JmsConfiguration configuration)
void
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
void
setDefaultTaskExecutorType(DefaultTaskExecutorType type)
void
setDeliveryMode(Integer deliveryMode)
void
setDeliveryPersistent(boolean deliveryPersistent)
void
setDestination(javax.jms.Destination destination)
Allows a specific JMS Destination object to be used as the destinationvoid
setDestinationName(String destinationName)
Name of the queue or topic to use as destinationvoid
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
void
setDestinationType(String destinationType)
The kind of destination to usevoid
setDisableReplyTo(boolean disableReplyTo)
void
setDisableTimeToLive(boolean disableTimeToLive)
void
setDurableSubscriptionName(String durableSubscriptionName)
void
setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
void
setEagerPoisonBody(String eagerPoisonBody)
void
setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
void
setErrorHandlerLogStackTrace(boolean errorHandlerLogStackTrace)
void
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
void
setExplicitQosEnabled(boolean explicitQosEnabled)
void
setExposeListenerSession(boolean exposeListenerSession)
void
setForceSendOriginalMessage(boolean forceSendOriginalMessage)
void
setFormatDateHeadersToIso8601(boolean formatDateHeadersToIso8601)
void
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
To use a custom HeaderFilterStrategy to filter header to and from Camel message.void
setIdleConsumerLimit(int idleConsumerLimit)
void
setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
void
setIncludeAllJMSXProperties(boolean includeAllJMSXProperties)
void
setIncludeSentJMSMessageID(boolean includeSentJMSMessageID)
void
setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsHeaderStrategy)
void
setJmsMessageType(JmsMessageType jmsMessageType)
void
setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
void
setLazyCreateTransactionManager(boolean lazyCreating)
void
setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)
void
setMaxConcurrentConsumers(int maxConcurrentConsumers)
void
setMaxMessagesPerTask(int maxMessagesPerTask)
void
setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
void
setMessageCreatedStrategy(MessageCreatedStrategy messageCreatedStrategy)
void
setMessageIdEnabled(boolean messageIdEnabled)
void
setMessageListenerContainerFactory(MessageListenerContainerFactory messageListenerContainerFactory)
void
setMessageTimestampEnabled(boolean messageTimestampEnabled)
void
setPreserveMessageQos(boolean preserveMessageQos)
void
setPriority(int priority)
void
setPubSubNoLocal(boolean pubSubNoLocal)
void
setReceiveTimeout(long receiveTimeout)
void
setRecoveryInterval(long recoveryInterval)
void
setReplyTo(String replyToDestination)
void
setReplyToCacheLevelName(String cacheName)
void
setReplyToConcurrentConsumers(int concurrentConsumers)
void
setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)
void
setReplyToDestinationSelectorName(String replyToDestinationSelectorName)
void
setReplyToMaxConcurrentConsumers(int maxConcurrentConsumers)
void
setReplyToOverride(String replyToDestination)
void
setReplyToSameDestinationAllowed(boolean replyToSameDestinationAllowed)
void
setReplyToType(String replyToType)
void
setRequestTimeout(long requestTimeout)
void
setSelector(String selector)
void
setSubscriptionDurable(boolean subscriptionDurable)
void
setSubscriptionName(String subscriptionName)
void
setSubscriptionShared(boolean subscriptionShared)
void
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
void
setTemplateConnectionFactory(javax.jms.ConnectionFactory templateConnectionFactory)
void
setTestConnectionOnStartup(boolean testConnectionOnStartup)
void
setTimeToLive(long timeToLive)
void
setTransacted(boolean transacted)
void
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
void
setTransactionName(String transactionName)
void
setTransactionTimeout(int transactionTimeout)
void
setTransferException(boolean transferException)
void
setTransferExchange(boolean transferExchange)
void
setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
void
setWaitForProvisionCorrelationToBeUpdatedCounter(int counter)
void
setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(long sleepingTime)
void
shutdown()
void
stop()
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createExchange, doInit, doStart, doStop, equals, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, start, suspend
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.camel.Endpoint
configureProperties, createAsyncProducer, createExchange, getCamelContext, getEndpointBaseUri, getEndpointKey, getEndpointUri, isLenientProperties, isSingletonProducer, setCamelContext
-
-
-
-
Constructor Detail
-
JmsEndpoint
public JmsEndpoint()
-
JmsEndpoint
public JmsEndpoint(javax.jms.Topic destination) throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
JmsEndpoint
public JmsEndpoint(String uri, JmsComponent component, String destinationName, boolean pubSubDomain, JmsConfiguration configuration)
-
JmsEndpoint
public JmsEndpoint(String endpointUri, JmsBinding binding, JmsConfiguration configuration, String destinationName, boolean pubSubDomain)
-
-
Method Detail
-
newInstance
public static JmsEndpoint newInstance(javax.jms.Destination destination, JmsComponent component) throws javax.jms.JMSException
Returns a new JMS endpoint for the given JMS destination using the configuration from the given JMS component- Throws:
javax.jms.JMSException
-
newInstance
public static JmsEndpoint newInstance(javax.jms.Destination destination) throws javax.jms.JMSException
Returns a new JMS endpoint for the given JMS destination- Throws:
javax.jms.JMSException
-
createProducer
public org.apache.camel.Producer createProducer() throws Exception
- Specified by:
createProducer
in interfaceorg.apache.camel.Endpoint
- Throws:
Exception
-
createConsumer
public JmsConsumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Specified by:
createConsumer
in interfaceorg.apache.camel.Endpoint
- Throws:
Exception
-
createMessageListenerContainer
public org.springframework.jms.listener.AbstractMessageListenerContainer createMessageListenerContainer() throws Exception
- Throws:
Exception
-
configureListenerContainer
public void configureListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer, JmsConsumer consumer)
-
getEndpointConfiguredDestinationName
public String getEndpointConfiguredDestinationName()
Gets the destination name which was configured from the endpoint uri.- Returns:
- the destination name resolved from the endpoint uri
-
createConsumer
public JmsConsumer createConsumer(org.apache.camel.Processor processor, org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer) throws Exception
Creates a consumer using the given processor and listener container- Parameters:
processor
- the processor to use to process the messageslistenerContainer
- the listener container- Returns:
- a newly created consumer
- Throws:
Exception
- if the consumer cannot be created
-
createPollingConsumer
public org.apache.camel.PollingConsumer createPollingConsumer() throws Exception
- Specified by:
createPollingConsumer
in interfaceorg.apache.camel.Endpoint
- Overrides:
createPollingConsumer
in classorg.apache.camel.support.DefaultEndpoint
- Throws:
Exception
-
createExchange
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern)
- Specified by:
createExchange
in interfaceorg.apache.camel.Endpoint
- Overrides:
createExchange
in classorg.apache.camel.support.DefaultEndpoint
-
createExchange
public org.apache.camel.Exchange createExchange(javax.jms.Message message, javax.jms.Session session)
-
createInOnlyTemplate
public org.springframework.jms.core.JmsOperations createInOnlyTemplate()
Factory method for creating a new template for InOnly message exchanges
-
createInOutTemplate
public org.springframework.jms.core.JmsOperations createInOutTemplate()
Factory method for creating a new template for InOut message exchanges
-
isMultipleConsumersSupported
public boolean isMultipleConsumersSupported()
- Specified by:
isMultipleConsumersSupported
in interfaceorg.apache.camel.MultipleConsumersSupport
-
getThreadName
public String getThreadName()
-
getComponent
public JmsComponent getComponent()
- Overrides:
getComponent
in classorg.apache.camel.support.DefaultEndpoint
-
getHeaderFilterStrategy
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
- Specified by:
getHeaderFilterStrategy
in interfaceorg.apache.camel.spi.HeaderFilterStrategyAware
-
setHeaderFilterStrategy
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
To use a custom HeaderFilterStrategy to filter header to and from Camel message.- Specified by:
setHeaderFilterStrategy
in interfaceorg.apache.camel.spi.HeaderFilterStrategyAware
-
getBinding
public JmsBinding getBinding()
-
createBinding
protected JmsBinding createBinding()
Creates theJmsBinding
to use.
-
setBinding
public void setBinding(JmsBinding binding)
Sets the binding used to convert from a Camel message to and from a JMS message
-
getDestinationType
public String getDestinationType()
-
setDestinationType
public void setDestinationType(String destinationType)
The kind of destination to use
-
getDestinationName
public String getDestinationName()
-
setDestinationName
public void setDestinationName(String destinationName)
Name of the queue or topic to use as destination
-
getDestination
public javax.jms.Destination getDestination()
-
setDestination
public void setDestination(javax.jms.Destination destination)
Allows a specific JMS Destination object to be used as the destination
-
getConfiguration
public JmsConfiguration getConfiguration()
-
setConfiguration
public void setConfiguration(JmsConfiguration configuration)
-
isPubSubDomain
@ManagedAttribute public boolean isPubSubDomain()
-
getAsyncStartStopExecutorService
protected ExecutorService getAsyncStartStopExecutorService()
-
onListenerContainerStarting
public void onListenerContainerStarting(org.springframework.jms.listener.AbstractMessageListenerContainer container)
-
onListenerContainerStopped
public void onListenerContainerStopped(org.springframework.jms.listener.AbstractMessageListenerContainer container)
-
isRunning
protected boolean isRunning()
State whether this endpoint is running (eg started)
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.camel.Service
- Overrides:
stop
in classorg.apache.camel.support.service.BaseService
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceorg.apache.camel.ShutdownableService
- Overrides:
shutdown
in classorg.apache.camel.support.service.BaseService
-
getAcknowledgementMode
@ManagedAttribute public int getAcknowledgementMode()
-
getAcknowledgementModeName
@ManagedAttribute public String getAcknowledgementModeName()
-
getCacheLevel
@ManagedAttribute public int getCacheLevel()
-
getCacheLevelName
@ManagedAttribute public String getCacheLevelName()
-
getReplyToCacheLevelName
@ManagedAttribute public String getReplyToCacheLevelName()
-
getClientId
@ManagedAttribute public String getClientId()
-
getConcurrentConsumers
@ManagedAttribute public int getConcurrentConsumers()
-
getReplyToConcurrentConsumers
@ManagedAttribute public int getReplyToConcurrentConsumers()
-
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
-
getDestinationResolver
public org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()
-
getDurableSubscriptionName
@ManagedAttribute public String getDurableSubscriptionName()
-
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
-
getErrorHandler
public org.springframework.util.ErrorHandler getErrorHandler()
-
getErrorHandlerLoggingLevel
public org.apache.camel.LoggingLevel getErrorHandlerLoggingLevel()
-
isErrorHandlerLogStackTrace
@ManagedAttribute public boolean isErrorHandlerLogStackTrace()
-
setErrorHandlerLogStackTrace
@ManagedAttribute public void setErrorHandlerLogStackTrace(boolean errorHandlerLogStackTrace)
-
getIdleTaskExecutionLimit
@ManagedAttribute public int getIdleTaskExecutionLimit()
-
getIdleConsumerLimit
@ManagedAttribute public int getIdleConsumerLimit()
-
getJmsOperations
public org.springframework.jms.core.JmsOperations getJmsOperations()
-
getListenerConnectionFactory
public javax.jms.ConnectionFactory getListenerConnectionFactory()
-
getMaxConcurrentConsumers
@ManagedAttribute public int getMaxConcurrentConsumers()
-
getReplyToMaxConcurrentConsumers
@ManagedAttribute public int getReplyToMaxConcurrentConsumers()
-
getReplyToOnTimeoutMaxConcurrentConsumers
@ManagedAttribute public int getReplyToOnTimeoutMaxConcurrentConsumers()
-
getMaxMessagesPerTask
@ManagedAttribute public int getMaxMessagesPerTask()
-
getMessageConverter
public org.springframework.jms.support.converter.MessageConverter getMessageConverter()
-
getPriority
@ManagedAttribute public int getPriority()
-
getReceiveTimeout
@ManagedAttribute public long getReceiveTimeout()
-
getRecoveryInterval
@ManagedAttribute public long getRecoveryInterval()
-
getReplyTo
@ManagedAttribute public String getReplyTo()
-
getReplyToOverride
@ManagedAttribute public String getReplyToOverride()
-
isReplyToSameDestinationAllowed
@ManagedAttribute public boolean isReplyToSameDestinationAllowed()
-
getReplyToDestinationSelectorName
@ManagedAttribute public String getReplyToDestinationSelectorName()
-
getRequestTimeout
@ManagedAttribute public long getRequestTimeout()
-
getRequestTimeoutCheckerInterval
@ManagedAttribute public long getRequestTimeoutCheckerInterval()
-
getTaskExecutor
public org.springframework.core.task.TaskExecutor getTaskExecutor()
-
getTemplateConnectionFactory
public javax.jms.ConnectionFactory getTemplateConnectionFactory()
-
getTimeToLive
@ManagedAttribute public long getTimeToLive()
-
getTransactionManager
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
-
getTransactionName
@ManagedAttribute public String getTransactionName()
-
getTransactionTimeout
@ManagedAttribute public int getTransactionTimeout()
-
isAcceptMessagesWhileStopping
@ManagedAttribute public boolean isAcceptMessagesWhileStopping()
-
isAllowReplyManagerQuickStop
@ManagedAttribute public boolean isAllowReplyManagerQuickStop()
-
isAlwaysCopyMessage
@ManagedAttribute public boolean isAlwaysCopyMessage()
-
isAutoStartup
@ManagedAttribute public boolean isAutoStartup()
-
isDeliveryPersistent
@ManagedAttribute public boolean isDeliveryPersistent()
-
getDeliveryMode
@ManagedAttribute public Integer getDeliveryMode()
-
isDisableReplyTo
@ManagedAttribute public boolean isDisableReplyTo()
-
getEagerPoisonBody
@ManagedAttribute public String getEagerPoisonBody()
-
isEagerLoadingOfProperties
@ManagedAttribute public boolean isEagerLoadingOfProperties()
-
isExplicitQosEnabled
@ManagedAttribute public boolean isExplicitQosEnabled()
-
isExposeListenerSession
@ManagedAttribute public boolean isExposeListenerSession()
-
isMessageIdEnabled
@ManagedAttribute public boolean isMessageIdEnabled()
-
isMessageTimestampEnabled
@ManagedAttribute public boolean isMessageTimestampEnabled()
-
isPreserveMessageQos
@ManagedAttribute public boolean isPreserveMessageQos()
-
isPubSubNoLocal
@ManagedAttribute public boolean isPubSubNoLocal()
-
isReplyToDeliveryPersistent
@ManagedAttribute public boolean isReplyToDeliveryPersistent()
-
isTransacted
@ManagedAttribute public boolean isTransacted()
-
isTransactedInOut
@ManagedAttribute public boolean isTransactedInOut()
-
isLazyCreateTransactionManager
@ManagedAttribute public boolean isLazyCreateTransactionManager()
-
isUseMessageIDAsCorrelationID
@ManagedAttribute public boolean isUseMessageIDAsCorrelationID()
-
setAcceptMessagesWhileStopping
@ManagedAttribute public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
-
setAllowReplyManagerQuickStop
@ManagedAttribute public void setAllowReplyManagerQuickStop(boolean allowReplyManagerQuickStop)
-
setAcknowledgementMode
@ManagedAttribute public void setAcknowledgementMode(int consumerAcknowledgementMode)
-
setAcknowledgementModeName
@ManagedAttribute public void setAcknowledgementModeName(String consumerAcknowledgementMode)
-
setAlwaysCopyMessage
@ManagedAttribute public void setAlwaysCopyMessage(boolean alwaysCopyMessage)
-
setAutoStartup
@ManagedAttribute public void setAutoStartup(boolean autoStartup)
-
setCacheLevel
@ManagedAttribute public void setCacheLevel(int cacheLevel)
-
setCacheLevelName
@ManagedAttribute public void setCacheLevelName(String cacheName)
-
setReplyToCacheLevelName
@ManagedAttribute public void setReplyToCacheLevelName(String cacheName)
-
setClientId
@ManagedAttribute public void setClientId(String consumerClientId)
-
setConcurrentConsumers
@ManagedAttribute public void setConcurrentConsumers(int concurrentConsumers)
-
setReplyToConcurrentConsumers
@ManagedAttribute public void setReplyToConcurrentConsumers(int concurrentConsumers)
-
setConnectionFactory
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
-
setDeliveryPersistent
@ManagedAttribute public void setDeliveryPersistent(boolean deliveryPersistent)
-
setDeliveryMode
@ManagedAttribute public void setDeliveryMode(Integer deliveryMode)
-
setDestinationResolver
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
-
setDisableReplyTo
@ManagedAttribute public void setDisableReplyTo(boolean disableReplyTo)
-
setDurableSubscriptionName
@ManagedAttribute public void setDurableSubscriptionName(String durableSubscriptionName)
-
setEagerPoisonBody
@ManagedAttribute public void setEagerPoisonBody(String eagerPoisonBody)
-
setEagerLoadingOfProperties
@ManagedAttribute public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
-
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
-
setErrorHandler
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
-
setExplicitQosEnabled
@ManagedAttribute public void setExplicitQosEnabled(boolean explicitQosEnabled)
-
setExposeListenerSession
@ManagedAttribute public void setExposeListenerSession(boolean exposeListenerSession)
-
setIdleTaskExecutionLimit
@ManagedAttribute public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
-
setIdleConsumerLimit
@ManagedAttribute public void setIdleConsumerLimit(int idleConsumerLimit)
-
setJmsOperations
public void setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
-
setListenerConnectionFactory
public void setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)
-
setMaxConcurrentConsumers
@ManagedAttribute public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
-
setReplyToMaxConcurrentConsumers
@ManagedAttribute public void setReplyToMaxConcurrentConsumers(int maxConcurrentConsumers)
-
setMaxMessagesPerTask
@ManagedAttribute public void setMaxMessagesPerTask(int maxMessagesPerTask)
-
setMessageConverter
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
-
setMessageIdEnabled
@ManagedAttribute public void setMessageIdEnabled(boolean messageIdEnabled)
-
setMessageTimestampEnabled
@ManagedAttribute public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
-
setPreserveMessageQos
@ManagedAttribute public void setPreserveMessageQos(boolean preserveMessageQos)
-
setPriority
@ManagedAttribute public void setPriority(int priority)
-
setPubSubNoLocal
@ManagedAttribute public void setPubSubNoLocal(boolean pubSubNoLocal)
-
setReceiveTimeout
@ManagedAttribute public void setReceiveTimeout(long receiveTimeout)
-
setRecoveryInterval
@ManagedAttribute public void setRecoveryInterval(long recoveryInterval)
-
setReplyTo
@ManagedAttribute public void setReplyTo(String replyToDestination)
-
setReplyToOverride
@ManagedAttribute public void setReplyToOverride(String replyToDestination)
-
setReplyToSameDestinationAllowed
@ManagedAttribute public void setReplyToSameDestinationAllowed(boolean replyToSameDestinationAllowed)
-
setReplyToDeliveryPersistent
@ManagedAttribute public void setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)
-
setReplyToDestinationSelectorName
@ManagedAttribute public void setReplyToDestinationSelectorName(String replyToDestinationSelectorName)
-
setRequestTimeout
@ManagedAttribute public void setRequestTimeout(long requestTimeout)
-
setTaskExecutor
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
-
setTemplateConnectionFactory
public void setTemplateConnectionFactory(javax.jms.ConnectionFactory templateConnectionFactory)
-
setTimeToLive
@ManagedAttribute public void setTimeToLive(long timeToLive)
-
setTransacted
@ManagedAttribute public void setTransacted(boolean transacted)
-
setLazyCreateTransactionManager
@ManagedAttribute public void setLazyCreateTransactionManager(boolean lazyCreating)
-
setTransactionManager
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
-
setTransactionName
@ManagedAttribute public void setTransactionName(String transactionName)
-
setTransactionTimeout
@ManagedAttribute public void setTransactionTimeout(int transactionTimeout)
-
setUseMessageIDAsCorrelationID
@ManagedAttribute public void setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
-
getJmsMessageType
public JmsMessageType getJmsMessageType()
-
setJmsMessageType
public void setJmsMessageType(JmsMessageType jmsMessageType)
-
getJmsKeyFormatStrategy
public JmsKeyFormatStrategy getJmsKeyFormatStrategy()
-
setJmsKeyFormatStrategy
public void setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsHeaderStrategy)
-
getMessageCreatedStrategy
public MessageCreatedStrategy getMessageCreatedStrategy()
-
setMessageCreatedStrategy
public void setMessageCreatedStrategy(MessageCreatedStrategy messageCreatedStrategy)
-
isTransferExchange
@ManagedAttribute public boolean isTransferExchange()
-
setTransferExchange
@ManagedAttribute public void setTransferExchange(boolean transferExchange)
-
isAllowSerializedHeaders
@ManagedAttribute public boolean isAllowSerializedHeaders()
-
setAllowSerializedHeaders
@ManagedAttribute public void setAllowSerializedHeaders(boolean allowSerializedHeaders)
-
isTransferException
@ManagedAttribute public boolean isTransferException()
-
setTransferException
@ManagedAttribute public void setTransferException(boolean transferException)
-
isTestConnectionOnStartup
@ManagedAttribute public boolean isTestConnectionOnStartup()
-
setTestConnectionOnStartup
@ManagedAttribute public void setTestConnectionOnStartup(boolean testConnectionOnStartup)
-
isForceSendOriginalMessage
@ManagedAttribute public boolean isForceSendOriginalMessage()
-
setForceSendOriginalMessage
@ManagedAttribute public void setForceSendOriginalMessage(boolean forceSendOriginalMessage)
-
isDisableTimeToLive
@ManagedAttribute public boolean isDisableTimeToLive()
-
setDisableTimeToLive
@ManagedAttribute public void setDisableTimeToLive(boolean disableTimeToLive)
-
setAsyncConsumer
@ManagedAttribute public void setAsyncConsumer(boolean asyncConsumer)
-
isAsyncConsumer
@ManagedAttribute public boolean isAsyncConsumer()
-
setAsyncStartListener
@ManagedAttribute public void setAsyncStartListener(boolean asyncStartListener)
-
isAsyncStartListener
@ManagedAttribute public boolean isAsyncStartListener()
-
setAsyncStopListener
@ManagedAttribute public void setAsyncStopListener(boolean asyncStopListener)
-
isAsyncStopListener
@ManagedAttribute public boolean isAsyncStopListener()
-
isAllowNullBody
@ManagedAttribute public boolean isAllowNullBody()
-
setAllowNullBody
@ManagedAttribute public void setAllowNullBody(boolean allowNullBody)
-
isIncludeSentJMSMessageID
@ManagedAttribute public boolean isIncludeSentJMSMessageID()
-
setIncludeSentJMSMessageID
@ManagedAttribute public void setIncludeSentJMSMessageID(boolean includeSentJMSMessageID)
-
isIncludeAllJMSXProperties
@ManagedAttribute public boolean isIncludeAllJMSXProperties()
-
setIncludeAllJMSXProperties
@ManagedAttribute public void setIncludeAllJMSXProperties(boolean includeAllJMSXProperties)
-
getDefaultTaskExecutorType
@ManagedAttribute public DefaultTaskExecutorType getDefaultTaskExecutorType()
-
setDefaultTaskExecutorType
public void setDefaultTaskExecutorType(DefaultTaskExecutorType type)
-
getAllowAdditionalHeaders
@ManagedAttribute public String getAllowAdditionalHeaders()
-
setAllowAdditionalHeaders
@ManagedAttribute public void setAllowAdditionalHeaders(String allowAdditionalHeaders)
-
getMessageListenerContainerFactory
public MessageListenerContainerFactory getMessageListenerContainerFactory()
-
setMessageListenerContainerFactory
public void setMessageListenerContainerFactory(MessageListenerContainerFactory messageListenerContainerFactory)
-
isSubscriptionDurable
@ManagedAttribute public boolean isSubscriptionDurable()
-
setSubscriptionDurable
@ManagedAttribute public void setSubscriptionDurable(boolean subscriptionDurable)
-
isSubscriptionShared
@ManagedAttribute public boolean isSubscriptionShared()
-
setSubscriptionShared
@ManagedAttribute public void setSubscriptionShared(boolean subscriptionShared)
-
getSubscriptionName
@ManagedAttribute public String getSubscriptionName()
-
setSubscriptionName
@ManagedAttribute public void setSubscriptionName(String subscriptionName)
-
getReplyToType
@ManagedAttribute public String getReplyToType()
-
setReplyToType
@ManagedAttribute public void setReplyToType(String replyToType)
-
getRunningMessageListeners
@ManagedAttribute(description="Number of running message listeners") public int getRunningMessageListeners()
-
getSelector
@ManagedAttribute public String getSelector()
-
setSelector
public void setSelector(String selector)
-
getWaitForProvisionCorrelationToBeUpdatedCounter
@ManagedAttribute public int getWaitForProvisionCorrelationToBeUpdatedCounter()
-
setWaitForProvisionCorrelationToBeUpdatedCounter
@ManagedAttribute public void setWaitForProvisionCorrelationToBeUpdatedCounter(int counter)
-
getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime
@ManagedAttribute public long getWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime()
-
setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime
@ManagedAttribute public void setWaitForProvisionCorrelationToBeUpdatedThreadSleepingTime(long sleepingTime)
-
isFormatDateHeadersToIso8601
@ManagedAttribute public boolean isFormatDateHeadersToIso8601()
-
setFormatDateHeadersToIso8601
@ManagedAttribute public void setFormatDateHeadersToIso8601(boolean formatDateHeadersToIso8601)
-
isArtemisStreamingEnabled
@ManagedAttribute public boolean isArtemisStreamingEnabled()
-
setArtemisStreamingEnabled
@ManagedAttribute public void setArtemisStreamingEnabled(boolean artemisStreamingEnabled)
-
createEndpointUri
protected String createEndpointUri()
- Overrides:
createEndpointUri
in classorg.apache.camel.support.DefaultEndpoint
-
-