org.apache.camel.component.jms
Class JmsEndpoint

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

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

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)
 JmsProducer 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()
           
 String getReplyTo()
           
 String getReplyToDestinationSelectorName()
           
 String getReplyToTempDestinationAffinity()
           
 long getRequestMapPurgePollTimeMillis()
           
 Requestor getRequestor()
           
 long getRequestTimeout()
           
 String getSelector()
           
 TaskExecutor getTaskExecutor()
           
 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()
          Wheter this class supports being singleton or not.
 boolean isSubscriptionDurable()
           
 boolean isTestConnectionOnStartup()
           
 boolean isTransacted()
           
 boolean isTransactedInOut()
           
 boolean isTransferException()
           
 boolean isTransferExchange()
           
 boolean isUseMessageIDAsCorrelationID()
           
 boolean isUseVersion102()
          Deprecated. will be removed in Camel 2.2
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 setReplyToTempDestinationAffinity(String replyToTempDestinationAffinity)
           
 void setRequestMapPurgePollTimeMillis(long requestMapPurgePollTimeMillis)
           
 void setRequestor(Requestor requestor)
           
 void setRequestTimeout(long requestTimeout)
           
 void setSelector(String selector)
          Sets the JMS selector to use
 void setSubscriptionDurable(boolean subscriptionDurable)
           
 void setTaskExecutor(TaskExecutor 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 setUseVersion102(boolean useVersion102)
          Deprecated. will be removed in Camel 2.2
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureProperties, createExchange, createExchange, createScheduledExecutorService, equals, getCamelContext, getComponent, getEndpointKey, getExchangePattern, getExchangeType, getExecutorService, getScheduledExecutorService, hashCode, isLenientProperties, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setExecutorService, 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 JmsProducer 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
Wheter 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.

getRequestor

public Requestor getRequestor()
                       throws Exception
Throws:
Exception

setRequestor

public void setRequestor(Requestor requestor)

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


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

getReplyToTempDestinationAffinity

public String getReplyToTempDestinationAffinity()

getRequestMapPurgePollTimeMillis

public long getRequestMapPurgePollTimeMillis()

getRequestTimeout

@ManagedAttribute
public long getRequestTimeout()

getTaskExecutor

public TaskExecutor getTaskExecutor()

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

isUseVersion102

@Deprecated
public boolean isUseVersion102()
Deprecated. will be removed in Camel 2.2


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)

setReplyToTempDestinationAffinity

public void setReplyToTempDestinationAffinity(String replyToTempDestinationAffinity)

setRequestMapPurgePollTimeMillis

public void setRequestMapPurgePollTimeMillis(long requestMapPurgePollTimeMillis)

setRequestTimeout

@ManagedAttribute
public void setRequestTimeout(long requestTimeout)

setSubscriptionDurable

@ManagedAttribute
public void setSubscriptionDurable(boolean subscriptionDurable)

setTaskExecutor

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

setUseVersion102

@Deprecated
public void setUseVersion102(boolean useVersion102)
Deprecated. will be removed in Camel 2.2


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


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.