org.apache.camel.component.jms
Class JmsEndpoint

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.component.jms.JmsEndpoint
All Implemented Interfaces:
CamelContextAware, Endpoint, IsSingleton, MultipleConsumersSupport, Service, ShutdownableService, HasId, HeaderFilterStrategyAware
Direct Known Subclasses:
JmsQueueEndpoint, JmsTemporaryTopicEndpoint

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

A JMS Endpoint

Version:

Field Summary
protected  org.slf4j.Logger log
           
 
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(javax.jms.Topic destination)
           
 
Method Summary
 void configureListenerContainer(org.springframework.jms.listener.DefaultMessageListenerContainer listenerContainer, JmsConsumer consumer)
           
 JmsConsumer createConsumer(Processor processor)
          Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
 JmsConsumer createConsumer(Processor processor, org.springframework.jms.listener.DefaultMessageListenerContainer 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(javax.jms.Message message)
           
 org.springframework.jms.core.JmsOperations createInOnlyTemplate()
          Factory method for creating a new template for InOnly message exchanges
 org.springframework.jms.core.JmsOperations createInOutTemplate()
          Factory method for creating a new template for InOut message exchanges
 org.springframework.jms.listener.DefaultMessageListenerContainer 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
protected  void doStart()
           
protected  void doStop()
           
 int getAcknowledgementMode()
           
 String getAcknowledgementModeName()
           
 JmsBinding getBinding()
           
 int getCacheLevel()
           
 String getCacheLevelName()
           
 String getCamelId()
           
 String getClientId()
           
 int getConcurrentConsumers()
           
 JmsConfiguration getConfiguration()
           
 javax.jms.ConnectionFactory getConnectionFactory()
           
 javax.jms.Destination getDestination()
           
 String getDestinationName()
           
 org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()
           
 String getDurableSubscriptionName()
           
 String getEndpointConfiguredDestinationName()
          Gets the destination name which was configured from the endpoint uri.
 String getEndpointUri()
          Returns the string representation of the endpoint URI
 javax.jms.ExceptionListener getExceptionListener()
           
 HeaderFilterStrategy getHeaderFilterStrategy()
          Gets the header filter strategy used
 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()
           
protected  org.springframework.jms.core.JmsOperations getMetadataJmsOperations()
          Returns the JmsOperations used for metadata operations such as creating temporary destinations
 org.springframework.jms.core.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()
           
 String getState()
           
 org.springframework.core.task.TaskExecutor getTaskExecutor()
           
 javax.jms.ConnectionFactory getTemplateConnectionFactory()
           
 Class<? extends javax.jms.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 javax.jms.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()
           
 org.springframework.transaction.PlatformTransactionManager getTransactionManager()
           
 String getTransactionName()
           
 int getTransactionTimeout()
           
 boolean isAcceptMessagesWhileStopping()
           
 boolean isAlwaysCopyMessage()
           
 boolean isAutoStartup()
           
 boolean isDeliveryPersistent()
           
 boolean isDisableReplyTo()
           
 boolean isEagerLoadingOfProperties()
           
 boolean isExplicitQosEnabled()
           
 boolean isExposeListenerSession()
           
 boolean isForceSendOriginalMessage()
           
 boolean isMessageIdEnabled()
           
 boolean isMessageTimestampEnabled()
           
 boolean isMultipleConsumersSupported()
          Is multiple consumers supported?
 boolean isPreserveMessageQos()
           
 boolean isPubSubDomain()
           
 boolean isPubSubNoLocal()
           
 boolean isReplyToDeliveryPersistent()
           
protected  boolean isRunning()
          State whether this endpoint is running (eg started)
 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(javax.jms.Destination destination)
          Returns a new JMS endpoint for the given JMS destination
static 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 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(javax.jms.ConnectionFactory connectionFactory)
           
 void setDeliveryPersistent(boolean deliveryPersistent)
           
 void setDestination(javax.jms.Destination destination)
          Allows a specific JMS Destination object to be used as the destination
 void setDestinationName(String destinationName)
           
 void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
           
 void setDisableReplyTo(boolean disableReplyTo)
           
 void setDurableSubscriptionName(String durableSubscriptionName)
           
 void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
           
 void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
           
 void setExplicitQosEnabled(boolean explicitQosEnabled)
           
 void setExposeListenerSession(boolean exposeListenerSession)
           
 void setForceSendOriginalMessage(boolean forceSendOriginalMessage)
           
 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(org.springframework.jms.core.JmsOperations jmsOperations)
           
 void setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)
           
 void setMaxConcurrentConsumers(int maxConcurrentConsumers)
           
 void setMaxMessagesPerTask(int maxMessagesPerTask)
           
 void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
           
 void setMessageIdEnabled(boolean messageIdEnabled)
           
 void setMessageTimestampEnabled(boolean messageTimestampEnabled)
           
 void setMetadataJmsOperations(org.springframework.jms.core.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(org.springframework.core.task.TaskExecutor taskExecutor)
           
 void setTemplateConnectionFactory(javax.jms.ConnectionFactory templateConnectionFactory)
           
 void setTestConnectionOnStartup(boolean testConnectionOnStartup)
           
 void setTimeToLive(long timeToLive)
           
 void setTransacted(boolean consumerTransacted)
           
 void setTransactedInOut(boolean transactedInOut)
           
 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)
           
 
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 org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Field Detail

log

protected final org.slf4j.Logger log
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)

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(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 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 org.springframework.jms.listener.DefaultMessageListenerContainer createMessageListenerContainer()
                                                                                                throws Exception
Throws:
Exception

configureListenerContainer

public void configureListenerContainer(org.springframework.jms.listener.DefaultMessageListenerContainer 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(Processor processor,
                                  org.springframework.jms.listener.DefaultMessageListenerContainer 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(javax.jms.Message message)

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

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 javax.jms.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 javax.jms.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 org.springframework.jms.core.JmsOperations getMetadataJmsOperations()
Returns the JmsOperations used for metadata operations such as creating temporary destinations


getReplyManagerExecutorService

protected ScheduledExecutorService getReplyManagerExecutorService()

isRunning

protected boolean isRunning()
State whether this endpoint is running (eg started)


doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class DefaultEndpoint
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class DefaultEndpoint
Throws:
Exception

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 javax.jms.ConnectionFactory getConnectionFactory()

getDestinationResolver

public org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()

getDurableSubscriptionName

@ManagedAttribute
public String getDurableSubscriptionName()

getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()

getIdleTaskExecutionLimit

@ManagedAttribute
public int getIdleTaskExecutionLimit()

getJmsOperations

public org.springframework.jms.core.JmsOperations getJmsOperations()

getListenerConnectionFactory

public javax.jms.ConnectionFactory getListenerConnectionFactory()

getMaxConcurrentConsumers

@ManagedAttribute
public int getMaxConcurrentConsumers()

getMaxMessagesPerTask

@ManagedAttribute
public int getMaxMessagesPerTask()

getMessageConverter

public org.springframework.jms.support.converter.MessageConverter getMessageConverter()

getMetadataJmsOperations

public org.springframework.jms.core.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 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()

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(javax.jms.ConnectionFactory connectionFactory)

setDeliveryPersistent

@ManagedAttribute
public void setDeliveryPersistent(boolean deliveryPersistent)

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)

setEagerLoadingOfProperties

@ManagedAttribute
public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)

setExceptionListener

public void setExceptionListener(javax.jms.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(org.springframework.jms.core.JmsOperations jmsOperations)

setListenerConnectionFactory

public void setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)

setMaxConcurrentConsumers

@ManagedAttribute
public void setMaxConcurrentConsumers(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)

setMetadataJmsOperations

public void setMetadataJmsOperations(org.springframework.jms.core.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(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 consumerTransacted)

setTransactedInOut

@ManagedAttribute
public void setTransactedInOut(boolean transactedInOut)

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)

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)

isForceSendOriginalMessage

@ManagedAttribute
public boolean isForceSendOriginalMessage()

setForceSendOriginalMessage

@ManagedAttribute
public void setForceSendOriginalMessage(boolean forceSendOriginalMessage)

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

getState

@ManagedAttribute(description="Service State")
public String getState()

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


Apache CAMEL