org.apache.camel.component.jms
Class JmsEndpoint

java.lang.Object
  org.apache.camel.impl.DefaultEndpoint
      org.apache.camel.component.jms.JmsEndpoint

All Implemented Interfaces:

CamelContextAware, Endpoint, IsSingleton, MultipleConsumersSupport, Service, HasId, HeaderFilterStrategyAware, ManagementAware<JmsEndpoint>

Direct Known Subclasses:

JmsQueueEndpoint, JmsTemporaryTopicEndpoint

@ManagedResource(description="Managed JMS Endpoint")
public class JmsEndpoint
extends DefaultEndpoint
implements HeaderFilterStrategyAware, ManagementAware<JmsEndpoint>, MultipleConsumersSupport, Service

A JMS Endpoint

Version:

$Revision:520964 $

Constructor Summary

JmsEndpoint()

JmsEndpoint(String endpointUri, JmsBinding binding, JmsConfiguration configuration, String destinationName, boolean pubSubDomain)

JmsEndpoint(String uri, JmsComponent component, String destinationName, boolean pubSubDomain, JmsConfiguration configuration)

JmsEndpoint(String endpointUri, String destinationName)
Creates a pub-sub endpoint with the given destination

JmsEndpoint(String endpointUri, String destinationName, boolean pubSubDomain)

JmsEndpoint(Topic destination)

Method Summary

void	configureListenerContainer(AbstractMessageListenerContainer listenerContainer)
JmsConsumer	createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
JmsConsumer	createConsumer(Processor processor, AbstractMessageListenerContainer listenerContainer) Creates a consumer using the given processor and listener container
protected String	createEndpointUri() A factory method to lazily create the endpointUri if none is specified
Exchange	createExchange(ExchangePattern pattern) Create a new exchange for communicating with this endpoint with the specified ExchangePattern such as whether its going to be an ExchangePattern.InOnly or ExchangePattern.InOut exchange
Exchange	createExchange(Message message)
JmsOperations	createInOnlyTemplate() Factory method for creating a new template for InOnly message exchanges
JmsOperations	createInOutTemplate() Factory method for creating a new template for InOut message exchanges
AbstractMessageListenerContainer	createMessageListenerContainer()
PollingConsumer	createPollingConsumer() Creates a new Polling Consumer so that the caller can poll message exchanges from the consumer using PollingConsumer.receive(), PollingConsumer.receiveNoWait() or PollingConsumer.receive(long) whenever it is ready to do so rather than using the Event Based Consumer returned by Endpoint.createConsumer(Processor)
Producer	createProducer() Creates a new producer which is used send messages into the endpoint
int	getAcknowledgementMode()
String	getAcknowledgementModeName()
JmsBinding	getBinding()
int	getCacheLevel()
String	getCacheLevelName()
String	getCamelId()
String	getClientId()
int	getConcurrentConsumers()
JmsConfiguration	getConfiguration()
ConnectionFactory	getConnectionFactory()
ConsumerType	getConsumerType()
Destination	getDestination()
String	getDestinationName()
DestinationResolver	getDestinationResolver()
String	getDurableSubscriptionName()
String	getEndpointUri() Returns the string representation of the endpoint URI
ExceptionListener	getExceptionListener()
HeaderFilterStrategy	getHeaderFilterStrategy() Gets the header filter strategy used
int	getIdleTaskExecutionLimit()
JmsKeyFormatStrategy	getJmsKeyFormatStrategy()
JmsMessageType	getJmsMessageType()
JmsOperations	getJmsOperations()
ConnectionFactory	getListenerConnectionFactory()
Object	getManagedObject(JmsEndpoint endpoint) Gets the managed object
int	getMaxConcurrentConsumers()
int	getMaxMessagesPerTask()
MessageConverter	getMessageConverter()
protected JmsOperations	getMetadataJmsOperations() Returns the JmsOperations used for metadata operations such as creating temporary destinations
JmsOperations	getMetadataJmsOperations(JmsEndpoint endpoint)
int	getPriority()
protected JmsProviderMetadata	getProviderMetadata() Returns the provider metadata
long	getReceiveTimeout()
long	getRecoveryInterval()
ReplyManager	getReplyManager()
ReplyManager	getReplyManager(String replyTo)
protected ScheduledExecutorService	getReplyManagerExecutorService()
String	getReplyTo()
String	getReplyToDestinationSelectorName()
long	getRequestTimeout()
String	getSelector()
TaskExecutor	getTaskExecutor()
Object	getTaskExecutorSpring2()
ConnectionFactory	getTemplateConnectionFactory()
Class<? extends TemporaryQueue>	getTemporaryQueueType() Lazily loads the temporary queue type if one has not been explicitly configured via calling the JmsProviderMetadata.setTemporaryQueueType(Class) on the getConfiguration() instance
Class<? extends TemporaryTopic>	getTemporaryTopicType() Lazily loads the temporary topic type if one has not been explicitly configured via calling the JmsProviderMetadata.setTemporaryTopicType(Class) on the getConfiguration() instance
long	getTimeToLive()
PlatformTransactionManager	getTransactionManager()
String	getTransactionName()
int	getTransactionTimeout()
boolean	isAcceptMessagesWhileStopping()
boolean	isAlwaysCopyMessage()
boolean	isAutoStartup()
boolean	isDeliveryPersistent()
boolean	isDisableReplyTo()
boolean	isEagerLoadingOfProperties()
boolean	isExplicitQosEnabled()
boolean	isExposeListenerSession()
boolean	isMessageIdEnabled()
boolean	isMessageTimestampEnabled()
boolean	isMultipleConsumersSupported() Is multiple consumers supported?
boolean	isPreserveMessageQos()
boolean	isPubSubDomain()
boolean	isPubSubNoLocal()
boolean	isReplyToDeliveryPersistent()
boolean	isSingleton() Whether this class supports being singleton or not.
boolean	isSubscriptionDurable()
boolean	isTestConnectionOnStartup()
boolean	isTransacted()
boolean	isTransactedInOut()
boolean	isTransferException()
boolean	isTransferExchange()
boolean	isUseMessageIDAsCorrelationID()
static JmsEndpoint	newInstance(Destination destination) Returns a new JMS endpoint for the given JMS destination
static JmsEndpoint	newInstance(Destination destination, JmsComponent component) Returns a new JMS endpoint for the given JMS destination using the configuration from the given JMS component
void	setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
void	setAcknowledgementMode(int consumerAcknowledgementMode)
void	setAcknowledgementModeName(String consumerAcknowledgementMode)
void	setAlwaysCopyMessage(boolean alwaysCopyMessage)
void	setAutoStartup(boolean autoStartup)
void	setBinding(JmsBinding binding) Sets the binding used to convert from a Camel message to and from a JMS message
void	setCacheLevel(int cacheLevel)
void	setCacheLevelName(String cacheName)
void	setClientId(String consumerClientId)
void	setConcurrentConsumers(int concurrentConsumers)
void	setConfiguration(JmsConfiguration configuration)
void	setConnectionFactory(ConnectionFactory connectionFactory)
void	setConsumerType(ConsumerType consumerType)
void	setDeliveryPersistent(boolean deliveryPersistent)
void	setDestination(Destination destination) Allows a specific JMS Destination object to be used as the destination
void	setDestinationName(String destinationName)
void	setDestinationResolver(DestinationResolver destinationResolver)
void	setDisableReplyTo(boolean disableReplyTo)
void	setDurableSubscriptionName(String durableSubscriptionName)
void	setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
void	setExceptionListener(ExceptionListener exceptionListener)
void	setExplicitQosEnabled(boolean explicitQosEnabled)
void	setExposeListenerSession(boolean exposeListenerSession)
void	setHeaderFilterStrategy(HeaderFilterStrategy strategy) Sets the header filter strategy to use
void	setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
void	setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsHeaderStrategy)
void	setJmsMessageType(JmsMessageType jmsMessageType)
void	setJmsOperations(JmsOperations jmsOperations)
void	setListenerConnectionFactory(ConnectionFactory listenerConnectionFactory)
void	setMaxConcurrentConsumers(int maxConcurrentConsumers)
void	setMaxMessagesPerTask(int maxMessagesPerTask)
void	setMessageConverter(MessageConverter messageConverter)
void	setMessageIdEnabled(boolean messageIdEnabled)
void	setMessageTimestampEnabled(boolean messageTimestampEnabled)
void	setMetadataJmsOperations(JmsOperations metadataJmsOperations)
void	setPreserveMessageQos(boolean preserveMessageQos)
void	setPriority(int priority)
void	setProviderMetadata(JmsProviderMetadata providerMetadata)
void	setPubSubNoLocal(boolean pubSubNoLocal)
void	setReceiveTimeout(long receiveTimeout)
void	setRecoveryInterval(long recoveryInterval)
void	setReplyTo(String replyToDestination)
void	setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)
void	setReplyToDestinationSelectorName(String replyToDestinationSelectorName)
void	setRequestTimeout(long requestTimeout)
void	setSelector(String selector) Sets the JMS selector to use
void	setSubscriptionDurable(boolean subscriptionDurable)
void	setTaskExecutor(TaskExecutor taskExecutor)
void	setTaskExecutorSpring2(Object taskExecutor)
void	setTemplateConnectionFactory(ConnectionFactory templateConnectionFactory)
void	setTestConnectionOnStartup(boolean testConnectionOnStartup)
void	setTimeToLive(long timeToLive)
void	setTransacted(boolean consumerTransacted)
void	setTransactedInOut(boolean transactedInOut)
void	setTransactionManager(PlatformTransactionManager transactionManager)
void	setTransactionName(String transactionName)
void	setTransactionTimeout(int transactionTimeout)
void	setTransferException(boolean transferException)
void	setTransferExchange(boolean transferExchange)
void	setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
void	start() Starts the service
void	stop() Stops the service

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureProperties, createExchange, createExchange, equals, getCamelContext, getComponent, getEndpointKey, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JmsEndpoint

public JmsEndpoint()

JmsEndpoint

public JmsEndpoint(Topic destination)
            throws JMSException

Throws:

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)

JmsEndpoint

public JmsEndpoint(String endpointUri,
                   String destinationName,
                   boolean pubSubDomain)

JmsEndpoint

public JmsEndpoint(String endpointUri,
                   String destinationName)

Creates a pub-sub endpoint with the given destination

Method Detail

newInstance

public static JmsEndpoint newInstance(Destination destination,
                                      JmsComponent component)
                               throws JMSException

Returns a new JMS endpoint for the given JMS destination using the configuration from the given JMS component

Throws:

JMSException

newInstance

public static JmsEndpoint newInstance(Destination destination)
                               throws JMSException

Returns a new JMS endpoint for the given JMS destination

Throws:

JMSException

createProducer

public Producer createProducer()
                        throws Exception

Description copied from interface: Endpoint

Creates a new producer which is used send messages into the endpoint

Specified by:

createProducer in interface Endpoint

Returns:

a newly created producer

Throws:

Exception - can be thrown

createConsumer

public JmsConsumer createConsumer(Processor processor)
                           throws Exception

Description copied from interface: Endpoint

Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor

Specified by:

createConsumer in interface Endpoint

Parameters:

processor - the given processor

Returns:

a newly created consumer

Throws:

Exception - can be thrown

createMessageListenerContainer

public AbstractMessageListenerContainer createMessageListenerContainer()

configureListenerContainer

public void configureListenerContainer(AbstractMessageListenerContainer listenerContainer)

createConsumer

public JmsConsumer createConsumer(Processor processor,
                                  AbstractMessageListenerContainer listenerContainer)
                           throws Exception

Creates a consumer using the given processor and listener container

Parameters:

processor - the processor to use to process the messages

listenerContainer - the listener container

Returns:

a newly created consumer

Throws:

Exception - if the consumer cannot be created

createPollingConsumer

public PollingConsumer createPollingConsumer()
                                      throws Exception

Description copied from interface: Endpoint

Creates a new Polling Consumer so that the caller can poll message exchanges from the consumer using PollingConsumer.receive(), PollingConsumer.receiveNoWait() or PollingConsumer.receive(long) whenever it is ready to do so rather than using the Event Based Consumer returned by Endpoint.createConsumer(Processor)

Specified by:

createPollingConsumer in interface Endpoint

Overrides:

createPollingConsumer in class DefaultEndpoint

Returns:

a newly created pull consumer

Throws:

Exception - if the pull consumer could not be created

createExchange

public Exchange createExchange(ExchangePattern pattern)

Description copied from interface: Endpoint

Create a new exchange for communicating with this endpoint with the specified ExchangePattern such as whether its going to be an ExchangePattern.InOnly or ExchangePattern.InOut exchange

Specified by:

createExchange in interface Endpoint

Overrides:

createExchange in class DefaultEndpoint

Parameters:

pattern - the message exchange pattern for the exchange

Returns:

a new exchange

createExchange

public Exchange createExchange(Message message)

createInOnlyTemplate

public JmsOperations createInOnlyTemplate()

Factory method for creating a new template for InOnly message exchanges

createInOutTemplate

public JmsOperations createInOutTemplate()

Factory method for creating a new template for InOut message exchanges

getManagedObject

public Object getManagedObject(JmsEndpoint endpoint)

Description copied from interface: ManagementAware

Gets the managed object

Specified by:

getManagedObject in interface ManagementAware<JmsEndpoint>

Parameters:

endpoint - the object to be managed

Returns:

the managed object

isMultipleConsumersSupported

public boolean isMultipleConsumersSupported()

Description copied from interface: MultipleConsumersSupport

Is multiple consumers supported?

Specified by:

isMultipleConsumersSupported in interface MultipleConsumersSupport

Returns:

true if multiple consumers is supported

getHeaderFilterStrategy

public HeaderFilterStrategy getHeaderFilterStrategy()

Description copied from interface: HeaderFilterStrategyAware

Gets the header filter strategy used

Specified by:

getHeaderFilterStrategy in interface HeaderFilterStrategyAware

Returns:

the strategy

setHeaderFilterStrategy

public void setHeaderFilterStrategy(HeaderFilterStrategy strategy)

Description copied from interface: HeaderFilterStrategyAware

Sets the header filter strategy to use

Specified by:

setHeaderFilterStrategy in interface HeaderFilterStrategyAware

Parameters:

strategy - the strategy

getBinding

public JmsBinding getBinding()

setBinding

public void setBinding(JmsBinding binding)

Sets the binding used to convert from a Camel message to and from a JMS message

Parameters:

binding - the binding to use

getDestinationName

public String getDestinationName()

setDestinationName

public void setDestinationName(String destinationName)

getDestination

public Destination getDestination()

setDestination

public void setDestination(Destination destination)

Allows a specific JMS Destination object to be used as the destination

getConfiguration

public JmsConfiguration getConfiguration()

setConfiguration

public void setConfiguration(JmsConfiguration configuration)

getSelector

public String getSelector()

setSelector

public void setSelector(String selector)

Sets the JMS selector to use

isSingleton

@ManagedAttribute
public boolean isSingleton()

Description copied from interface: IsSingleton

Whether this class supports being singleton or not.

Specified by:

isSingleton in interface IsSingleton

Returns:

true to be a single shared instance, false to create new instances.

getReplyManager

public ReplyManager getReplyManager()
                             throws Exception

Throws:

Exception

getReplyManager

public ReplyManager getReplyManager(String replyTo)
                             throws Exception

Throws:

Exception

isPubSubDomain

public boolean isPubSubDomain()

getTemporaryQueueType

public Class<? extends TemporaryQueue> getTemporaryQueueType()

Lazily loads the temporary queue type if one has not been explicitly configured via calling the JmsProviderMetadata.setTemporaryQueueType(Class) on the getConfiguration() instance

getTemporaryTopicType

public Class<? extends TemporaryTopic> getTemporaryTopicType()

Lazily loads the temporary topic type if one has not been explicitly configured via calling the JmsProviderMetadata.setTemporaryTopicType(Class) on the getConfiguration() instance

getProviderMetadata

protected JmsProviderMetadata getProviderMetadata()

Returns the provider metadata

getMetadataJmsOperations

protected JmsOperations getMetadataJmsOperations()

Returns the JmsOperations used for metadata operations such as creating temporary destinations

getReplyManagerExecutorService

protected ScheduledExecutorService getReplyManagerExecutorService()

start

public void start()
           throws Exception

Description copied from interface: Service

Starts the service

Specified by:

start in interface Service

Overrides:

start in class DefaultEndpoint

Throws:

Exception - is thrown if starting failed

stop

public void stop()
          throws Exception

Description copied from interface: Service

Stops the service

Specified by:

stop in interface Service

Overrides:

stop in class DefaultEndpoint

Throws:

Exception - is thrown if stopping failed

getAcknowledgementMode

@ManagedAttribute
public int getAcknowledgementMode()

getAcknowledgementModeName

@ManagedAttribute
public String getAcknowledgementModeName()

getCacheLevel

@ManagedAttribute
public int getCacheLevel()

getCacheLevelName

@ManagedAttribute
public String getCacheLevelName()

getClientId

@ManagedAttribute
public String getClientId()

getConcurrentConsumers

@ManagedAttribute
public int getConcurrentConsumers()

getConnectionFactory

public ConnectionFactory getConnectionFactory()

getConsumerType

public ConsumerType getConsumerType()

getDestinationResolver

public DestinationResolver getDestinationResolver()

getDurableSubscriptionName

@ManagedAttribute
public String getDurableSubscriptionName()

getExceptionListener

public ExceptionListener getExceptionListener()

getIdleTaskExecutionLimit

@ManagedAttribute
public int getIdleTaskExecutionLimit()

getJmsOperations

public JmsOperations getJmsOperations()

getListenerConnectionFactory

public ConnectionFactory getListenerConnectionFactory()

getMaxConcurrentConsumers

@ManagedAttribute
public int getMaxConcurrentConsumers()

getMaxMessagesPerTask

@ManagedAttribute
public int getMaxMessagesPerTask()

getMessageConverter

public MessageConverter getMessageConverter()

getMetadataJmsOperations

public JmsOperations getMetadataJmsOperations(JmsEndpoint endpoint)

getPriority

@ManagedAttribute
public int getPriority()

getReceiveTimeout

@ManagedAttribute
public long getReceiveTimeout()

getRecoveryInterval

@ManagedAttribute
public long getRecoveryInterval()

getReplyTo

@ManagedAttribute
public String getReplyTo()

getReplyToDestinationSelectorName

@ManagedAttribute
public String getReplyToDestinationSelectorName()

getRequestTimeout

@ManagedAttribute
public long getRequestTimeout()

getTaskExecutor

public TaskExecutor getTaskExecutor()

getTaskExecutorSpring2

public Object getTaskExecutorSpring2()

getTemplateConnectionFactory

public ConnectionFactory getTemplateConnectionFactory()

getTimeToLive

@ManagedAttribute
public long getTimeToLive()

getTransactionManager

public PlatformTransactionManager getTransactionManager()

getTransactionName

@ManagedAttribute
public String getTransactionName()

getTransactionTimeout

@ManagedAttribute
public int getTransactionTimeout()

isAcceptMessagesWhileStopping

@ManagedAttribute
public boolean isAcceptMessagesWhileStopping()

isAlwaysCopyMessage

@ManagedAttribute
public boolean isAlwaysCopyMessage()

isAutoStartup

@ManagedAttribute
public boolean isAutoStartup()

isDeliveryPersistent

@ManagedAttribute
public boolean isDeliveryPersistent()

isDisableReplyTo

@ManagedAttribute
public boolean isDisableReplyTo()

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()

isSubscriptionDurable

@ManagedAttribute
public boolean isSubscriptionDurable()

isTransacted

@ManagedAttribute
public boolean isTransacted()

isTransactedInOut

@ManagedAttribute
public boolean isTransactedInOut()

isUseMessageIDAsCorrelationID

@ManagedAttribute
public boolean isUseMessageIDAsCorrelationID()

setAcceptMessagesWhileStopping

@ManagedAttribute
public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)

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)

setClientId

@ManagedAttribute
public void setClientId(String consumerClientId)

setConcurrentConsumers

@ManagedAttribute
public void setConcurrentConsumers(int concurrentConsumers)

setConnectionFactory

public void setConnectionFactory(ConnectionFactory connectionFactory)

setConsumerType

public void setConsumerType(ConsumerType consumerType)

setDeliveryPersistent

@ManagedAttribute
public void setDeliveryPersistent(boolean deliveryPersistent)

setDestinationResolver

public void setDestinationResolver(DestinationResolver destinationResolver)

setDisableReplyTo

@ManagedAttribute
public void setDisableReplyTo(boolean disableReplyTo)

setDurableSubscriptionName

@ManagedAttribute
public void setDurableSubscriptionName(String durableSubscriptionName)

setEagerLoadingOfProperties

@ManagedAttribute
public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)

setExceptionListener

public void setExceptionListener(ExceptionListener exceptionListener)

setExplicitQosEnabled

@ManagedAttribute
public void setExplicitQosEnabled(boolean explicitQosEnabled)

setExposeListenerSession

@ManagedAttribute
public void setExposeListenerSession(boolean exposeListenerSession)

setIdleTaskExecutionLimit

@ManagedAttribute
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)

setJmsOperations

public void setJmsOperations(JmsOperations jmsOperations)

setListenerConnectionFactory

public void setListenerConnectionFactory(ConnectionFactory listenerConnectionFactory)

setMaxConcurrentConsumers

@ManagedAttribute
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

setMaxMessagesPerTask

@ManagedAttribute
public void setMaxMessagesPerTask(int maxMessagesPerTask)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

setMessageIdEnabled

@ManagedAttribute
public void setMessageIdEnabled(boolean messageIdEnabled)

setMessageTimestampEnabled

@ManagedAttribute
public void setMessageTimestampEnabled(boolean messageTimestampEnabled)

setMetadataJmsOperations

public void setMetadataJmsOperations(JmsOperations metadataJmsOperations)

setPreserveMessageQos

@ManagedAttribute
public void setPreserveMessageQos(boolean preserveMessageQos)

setPriority

@ManagedAttribute
public void setPriority(int priority)

setProviderMetadata

public void setProviderMetadata(JmsProviderMetadata providerMetadata)

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)

setReplyToDeliveryPersistent

@ManagedAttribute
public void setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)

setReplyToDestinationSelectorName

@ManagedAttribute
public void setReplyToDestinationSelectorName(String replyToDestinationSelectorName)

setRequestTimeout

@ManagedAttribute
public void setRequestTimeout(long requestTimeout)

setSubscriptionDurable

@ManagedAttribute
public void setSubscriptionDurable(boolean subscriptionDurable)

setTaskExecutor

public void setTaskExecutor(TaskExecutor taskExecutor)

setTaskExecutorSpring2

public void setTaskExecutorSpring2(Object taskExecutor)

setTemplateConnectionFactory

public void setTemplateConnectionFactory(ConnectionFactory templateConnectionFactory)

setTimeToLive

@ManagedAttribute
public void setTimeToLive(long timeToLive)

setTransacted

@ManagedAttribute
public void setTransacted(boolean consumerTransacted)

setTransactedInOut

@ManagedAttribute
public void setTransactedInOut(boolean transactedInOut)

setTransactionManager

public void setTransactionManager(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)

isTransferExchange

@ManagedAttribute
public boolean isTransferExchange()

setTransferExchange

@ManagedAttribute
public void setTransferExchange(boolean transferExchange)

isTransferException

@ManagedAttribute
public boolean isTransferException()

setTransferException

@ManagedAttribute
public void setTransferException(boolean transferException)

isTestConnectionOnStartup

@ManagedAttribute
public boolean isTestConnectionOnStartup()

setTestConnectionOnStartup

@ManagedAttribute
public void setTestConnectionOnStartup(boolean testConnectionOnStartup)

getCamelId

@ManagedAttribute(description="Camel id")
public String getCamelId()

getEndpointUri

@ManagedAttribute(description="Endpoint Uri")
public String getEndpointUri()

Description copied from interface: Endpoint

Returns the string representation of the endpoint URI

Specified by:

getEndpointUri in interface Endpoint

Overrides:

getEndpointUri in class DefaultEndpoint

Returns:

the endpoint URI

createEndpointUri

protected String createEndpointUri()

Description copied from class: DefaultEndpoint

A factory method to lazily create the endpointUri if none is specified

Overrides:

createEndpointUri in class DefaultEndpoint