|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultEndpoint org.apache.camel.component.jms.JmsEndpoint
@ManagedResource(description="Managed JMS Endpoint") @UriEndpoint(scheme="jms", consumerClass=JmsConsumer.class) public class JmsEndpoint
Field Summary | |
---|---|
protected org.slf4j.Logger |
log
|
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
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.AbstractMessageListenerContainer listenerContainer,
JmsConsumer consumer)
|
JmsConsumer |
createConsumer(org.apache.camel.Processor processor)
|
JmsConsumer |
createConsumer(org.apache.camel.Processor processor,
org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
Creates a consumer using the given processor and listener container |
protected String |
createEndpointUri()
|
org.apache.camel.Exchange |
createExchange(org.apache.camel.ExchangePattern pattern)
|
org.apache.camel.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.AbstractMessageListenerContainer |
createMessageListenerContainer()
|
org.apache.camel.PollingConsumer |
createPollingConsumer()
|
org.apache.camel.Producer |
createProducer()
|
int |
getAcknowledgementMode()
|
String |
getAcknowledgementModeName()
|
protected ExecutorService |
getAsyncStartStopExecutorService()
|
JmsBinding |
getBinding()
|
int |
getCacheLevel()
|
String |
getCacheLevelName()
|
String |
getCamelId()
|
String |
getCamelManagementName()
|
String |
getClientId()
|
JmsComponent |
getComponent()
|
int |
getConcurrentConsumers()
|
JmsConfiguration |
getConfiguration()
|
javax.jms.ConnectionFactory |
getConnectionFactory()
|
DefaultTaskExecutorType |
getDefaultTaskExecutorType()
|
Integer |
getDeliveryMode()
|
javax.jms.Destination |
getDestination()
|
String |
getDestinationName()
|
org.springframework.jms.support.destination.DestinationResolver |
getDestinationResolver()
|
String |
getDurableSubscriptionName()
|
String |
getEndpointConfiguredDestinationName()
Gets the destination name which was configured from the endpoint uri. |
String |
getEndpointUri()
|
org.springframework.util.ErrorHandler |
getErrorHandler()
|
org.apache.camel.LoggingLevel |
getErrorHandlerLoggingLevel()
|
javax.jms.ExceptionListener |
getExceptionListener()
|
org.apache.camel.spi.HeaderFilterStrategy |
getHeaderFilterStrategy()
|
int |
getIdleConsumerLimit()
|
int |
getIdleTaskExecutionLimit()
|
JmsKeyFormatStrategy |
getJmsKeyFormatStrategy()
|
JmsMessageType |
getJmsMessageType()
|
org.springframework.jms.core.JmsOperations |
getJmsOperations()
|
javax.jms.ConnectionFactory |
getListenerConnectionFactory()
|
int |
getMaxConcurrentConsumers()
|
int |
getMaxMessagesPerTask()
|
org.springframework.jms.support.converter.MessageConverter |
getMessageConverter()
|
MessageListenerContainerFactory |
getMessageListenerContainerFactory()
|
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()
|
String |
getReplyTo()
|
String |
getReplyToCacheLevelName()
|
String |
getReplyToDestinationSelectorName()
|
String |
getReplyToType()
|
long |
getRequestTimeout()
|
long |
getRequestTimeoutCheckerInterval()
|
int |
getRunningMessageListeners()
|
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 |
String |
getThreadName()
|
long |
getTimeToLive()
|
org.springframework.transaction.PlatformTransactionManager |
getTransactionManager()
|
String |
getTransactionName()
|
int |
getTransactionTimeout()
|
boolean |
isAcceptMessagesWhileStopping()
|
boolean |
isAllowNullBody()
|
boolean |
isAlwaysCopyMessage()
|
boolean |
isAsyncConsumer()
|
boolean |
isAsyncStartListener()
|
boolean |
isAsyncStopListener()
|
boolean |
isAutoStartup()
|
boolean |
isDeliveryPersistent()
|
boolean |
isDisableReplyTo()
|
boolean |
isDisableTimeToLive()
|
boolean |
isEagerLoadingOfProperties()
|
boolean |
isErrorHandlerLogStackTrace()
|
boolean |
isExplicitQosEnabled()
|
boolean |
isExposeListenerSession()
|
boolean |
isForceSendOriginalMessage()
|
boolean |
isIncludeAllJMSXProperties()
|
boolean |
isIncludeSentJMSMessageID()
|
boolean |
isLazyCreateTransactionManager()
|
boolean |
isMessageIdEnabled()
|
boolean |
isMessageTimestampEnabled()
|
boolean |
isMultipleConsumersSupported()
|
boolean |
isPreserveMessageQos()
|
boolean |
isPubSubDomain()
|
boolean |
isPubSubNoLocal()
|
boolean |
isReplyToDeliveryPersistent()
|
protected boolean |
isRunning()
State whether this endpoint is running (eg started) |
boolean |
isSingleton()
|
boolean |
isSubscriptionDurable()
Deprecated. |
boolean |
isTestConnectionOnStartup()
|
boolean |
isTransacted()
|
boolean |
isTransactedInOut()
Deprecated. |
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 |
onListenerContainerStarting(org.springframework.jms.listener.AbstractMessageListenerContainer container)
|
void |
onListenerContainerStopped(org.springframework.jms.listener.AbstractMessageListenerContainer container)
|
void |
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
|
void |
setAcknowledgementMode(int consumerAcknowledgementMode)
|
void |
setAcknowledgementModeName(String consumerAcknowledgementMode)
|
void |
setAllowNullBody(boolean allowNullBody)
|
void |
setAlwaysCopyMessage(boolean alwaysCopyMessage)
|
void |
setAsyncConsumer(boolean asyncConsumer)
|
void |
setAsyncStartListener(boolean asyncStartListener)
|
void |
setAsyncStopListener(boolean asyncStopListener)
|
void |
setAutoStartup(boolean autoStartup)
|
void |
setBinding(JmsBinding binding)
Sets the binding used to convert from a Camel message to and from a JMS 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 |
setDefaultTaskExecutorType(DefaultTaskExecutorType type)
|
void |
setDeliveryMode(Integer deliveryMode)
|
void |
setDeliveryPersistent(boolean deliveryPersistent)
|
void |
setDestination(javax.jms.Destination destination)
Allows a specific JMS Destination object to be used as the destination |
void |
setDestinationName(String destinationName)
|
void |
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
|
void |
setDisableReplyTo(boolean disableReplyTo)
|
void |
setDisableTimeToLive(boolean disableTimeToLive)
|
void |
setDurableSubscriptionName(String durableSubscriptionName)
|
void |
setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
|
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
|
void |
setErrorHandlerLogStackTrace(boolean errorHandlerLogStackTrace)
|
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
|
void |
setExplicitQosEnabled(boolean explicitQosEnabled)
|
void |
setExposeListenerSession(boolean exposeListenerSession)
|
void |
setForceSendOriginalMessage(boolean forceSendOriginalMessage)
|
void |
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
|
void |
setIdleConsumerLimit(int idleConsumerLimit)
|
void |
setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
|
void |
setIncludeAllJMSXProperties(boolean includeAllJMSXProperties)
|
void |
setIncludeSentJMSMessageID(boolean includeSentJMSMessageID)
|
void |
setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsHeaderStrategy)
|
void |
setJmsMessageType(JmsMessageType jmsMessageType)
|
void |
setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
|
void |
setLazyCreateTransactionManager(boolean lazyCreating)
|
void |
setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)
|
void |
setMaxConcurrentConsumers(int maxConcurrentConsumers)
|
void |
setMaxMessagesPerTask(int maxMessagesPerTask)
|
void |
setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
|
void |
setMessageIdEnabled(boolean messageIdEnabled)
|
void |
setMessageListenerContainerFactory(MessageListenerContainerFactory messageListenerContainerFactory)
|
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 |
setReplyToCacheLevelName(String cacheName)
|
void |
setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)
|
void |
setReplyToDestinationSelectorName(String replyToDestinationSelectorName)
|
void |
setReplyToType(String replyToType)
|
void |
setRequestTimeout(long requestTimeout)
|
void |
setSelector(String selector)
Sets the JMS selector to use |
void |
setSubscriptionDurable(boolean subscriptionDurable)
Deprecated. |
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)
Deprecated. |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
|
void |
setTransactionName(String transactionName)
|
void |
setTransactionTimeout(int transactionTimeout)
|
void |
setTransferException(boolean transferException)
|
void |
setTransferExchange(boolean transferExchange)
|
void |
setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
|
void |
shutdown()
|
void |
stop()
|
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
---|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createExchange, createExchange, doStart, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, start, suspend |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start |
Field Detail |
---|
protected final org.slf4j.Logger log
Constructor Detail |
---|
public JmsEndpoint()
public JmsEndpoint(javax.jms.Topic destination) throws javax.jms.JMSException
javax.jms.JMSException
public JmsEndpoint(String uri, JmsComponent component, String destinationName, boolean pubSubDomain, JmsConfiguration configuration)
public JmsEndpoint(String endpointUri, JmsBinding binding, JmsConfiguration configuration, String destinationName, boolean pubSubDomain)
public JmsEndpoint(String endpointUri, String destinationName, boolean pubSubDomain)
public JmsEndpoint(String endpointUri, String destinationName)
Method Detail |
---|
public static JmsEndpoint newInstance(javax.jms.Destination destination, JmsComponent component) throws javax.jms.JMSException
javax.jms.JMSException
public static JmsEndpoint newInstance(javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public JmsConsumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public org.springframework.jms.listener.AbstractMessageListenerContainer createMessageListenerContainer() throws Exception
Exception
public void configureListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer, JmsConsumer consumer)
public String getEndpointConfiguredDestinationName()
public JmsConsumer createConsumer(org.apache.camel.Processor processor, org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer) throws Exception
processor
- the processor to use to process the messageslistenerContainer
- the listener container
Exception
- if the consumer cannot be createdpublic org.apache.camel.PollingConsumer createPollingConsumer() throws Exception
createPollingConsumer
in interface org.apache.camel.Endpoint
createPollingConsumer
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.apache.camel.Exchange createExchange(org.apache.camel.ExchangePattern pattern)
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.Exchange createExchange(javax.jms.Message message)
public org.springframework.jms.core.JmsOperations createInOnlyTemplate()
public org.springframework.jms.core.JmsOperations createInOutTemplate()
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
public String getThreadName()
public JmsComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
getHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
setHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public JmsBinding getBinding()
public void setBinding(JmsBinding binding)
binding
- the binding to usepublic String getDestinationName()
public void setDestinationName(String destinationName)
public javax.jms.Destination getDestination()
public void setDestination(javax.jms.Destination destination)
public JmsConfiguration getConfiguration()
public void setConfiguration(JmsConfiguration configuration)
public String getSelector()
public void setSelector(String selector)
@ManagedAttribute public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
@ManagedAttribute public boolean isPubSubDomain()
public Class<? extends javax.jms.TemporaryQueue> getTemporaryQueueType()
JmsProviderMetadata.setTemporaryQueueType(Class)
on the getConfiguration()
instance
public Class<? extends javax.jms.TemporaryTopic> getTemporaryTopicType()
JmsProviderMetadata.setTemporaryTopicType(Class)
on the getConfiguration()
instance
protected JmsProviderMetadata getProviderMetadata()
protected org.springframework.jms.core.JmsOperations getMetadataJmsOperations()
JmsOperations
used for metadata operations such as creating temporary destinations
protected ExecutorService getAsyncStartStopExecutorService()
public void onListenerContainerStarting(org.springframework.jms.listener.AbstractMessageListenerContainer container)
public void onListenerContainerStopped(org.springframework.jms.listener.AbstractMessageListenerContainer container)
protected boolean isRunning()
public void stop() throws Exception
stop
in interface org.apache.camel.Service
stop
in class org.apache.camel.support.ServiceSupport
Exception
public void shutdown() throws Exception
shutdown
in interface org.apache.camel.ShutdownableService
shutdown
in class org.apache.camel.support.ServiceSupport
Exception
@ManagedAttribute public int getAcknowledgementMode()
@ManagedAttribute public String getAcknowledgementModeName()
@ManagedAttribute public int getCacheLevel()
@ManagedAttribute public String getCacheLevelName()
@ManagedAttribute public String getReplyToCacheLevelName()
@ManagedAttribute public String getClientId()
@ManagedAttribute public int getConcurrentConsumers()
public javax.jms.ConnectionFactory getConnectionFactory()
public org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()
@ManagedAttribute public String getDurableSubscriptionName()
public javax.jms.ExceptionListener getExceptionListener()
public org.springframework.util.ErrorHandler getErrorHandler()
public org.apache.camel.LoggingLevel getErrorHandlerLoggingLevel()
@ManagedAttribute public boolean isErrorHandlerLogStackTrace()
@ManagedAttribute public void setErrorHandlerLogStackTrace(boolean errorHandlerLogStackTrace)
@ManagedAttribute public int getIdleTaskExecutionLimit()
@ManagedAttribute public int getIdleConsumerLimit()
public org.springframework.jms.core.JmsOperations getJmsOperations()
public javax.jms.ConnectionFactory getListenerConnectionFactory()
@ManagedAttribute public int getMaxConcurrentConsumers()
@ManagedAttribute public int getMaxMessagesPerTask()
public org.springframework.jms.support.converter.MessageConverter getMessageConverter()
public org.springframework.jms.core.JmsOperations getMetadataJmsOperations(JmsEndpoint endpoint)
@ManagedAttribute public int getPriority()
@ManagedAttribute public long getReceiveTimeout()
@ManagedAttribute public long getRecoveryInterval()
@ManagedAttribute public String getReplyTo()
@ManagedAttribute public String getReplyToDestinationSelectorName()
@ManagedAttribute public long getRequestTimeout()
@ManagedAttribute public long getRequestTimeoutCheckerInterval()
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public javax.jms.ConnectionFactory getTemplateConnectionFactory()
@ManagedAttribute public long getTimeToLive()
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
@ManagedAttribute public String getTransactionName()
@ManagedAttribute public int getTransactionTimeout()
@ManagedAttribute public boolean isAcceptMessagesWhileStopping()
@ManagedAttribute public boolean isAlwaysCopyMessage()
@ManagedAttribute public boolean isAutoStartup()
@ManagedAttribute public boolean isDeliveryPersistent()
@ManagedAttribute public Integer getDeliveryMode()
@ManagedAttribute public boolean isDisableReplyTo()
@ManagedAttribute public boolean isEagerLoadingOfProperties()
@ManagedAttribute public boolean isExplicitQosEnabled()
@ManagedAttribute public boolean isExposeListenerSession()
@ManagedAttribute public boolean isMessageIdEnabled()
@ManagedAttribute public boolean isMessageTimestampEnabled()
@ManagedAttribute public boolean isPreserveMessageQos()
@ManagedAttribute public boolean isPubSubNoLocal()
@ManagedAttribute public boolean isReplyToDeliveryPersistent()
@ManagedAttribute @Deprecated public boolean isSubscriptionDurable()
@ManagedAttribute public boolean isTransacted()
@ManagedAttribute public boolean isLazyCreateTransactionManager()
@ManagedAttribute @Deprecated public boolean isTransactedInOut()
@ManagedAttribute public boolean isUseMessageIDAsCorrelationID()
@ManagedAttribute public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
@ManagedAttribute public void setAcknowledgementMode(int consumerAcknowledgementMode)
@ManagedAttribute public void setAcknowledgementModeName(String consumerAcknowledgementMode)
@ManagedAttribute public void setAlwaysCopyMessage(boolean alwaysCopyMessage)
@ManagedAttribute public void setAutoStartup(boolean autoStartup)
@ManagedAttribute public void setCacheLevel(int cacheLevel)
@ManagedAttribute public void setCacheLevelName(String cacheName)
@ManagedAttribute public void setReplyToCacheLevelName(String cacheName)
@ManagedAttribute public void setClientId(String consumerClientId)
@ManagedAttribute public void setConcurrentConsumers(int concurrentConsumers)
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
@ManagedAttribute public void setDeliveryPersistent(boolean deliveryPersistent)
@ManagedAttribute public void setDeliveryMode(Integer deliveryMode)
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
@ManagedAttribute public void setDisableReplyTo(boolean disableReplyTo)
@ManagedAttribute public void setDurableSubscriptionName(String durableSubscriptionName)
@ManagedAttribute public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
@ManagedAttribute public void setExplicitQosEnabled(boolean explicitQosEnabled)
@ManagedAttribute public void setExposeListenerSession(boolean exposeListenerSession)
@ManagedAttribute public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
@ManagedAttribute public void setIdleConsumerLimit(int idleConsumerLimit)
public void setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
public void setListenerConnectionFactory(javax.jms.ConnectionFactory listenerConnectionFactory)
@ManagedAttribute public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
@ManagedAttribute public void setMaxMessagesPerTask(int maxMessagesPerTask)
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
@ManagedAttribute public void setMessageIdEnabled(boolean messageIdEnabled)
@ManagedAttribute public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
public void setMetadataJmsOperations(org.springframework.jms.core.JmsOperations metadataJmsOperations)
@ManagedAttribute public void setPreserveMessageQos(boolean preserveMessageQos)
@ManagedAttribute public void setPriority(int priority)
public void setProviderMetadata(JmsProviderMetadata providerMetadata)
@ManagedAttribute public void setPubSubNoLocal(boolean pubSubNoLocal)
@ManagedAttribute public void setReceiveTimeout(long receiveTimeout)
@ManagedAttribute public void setRecoveryInterval(long recoveryInterval)
@ManagedAttribute public void setReplyTo(String replyToDestination)
@ManagedAttribute public void setReplyToDeliveryPersistent(boolean replyToDeliveryPersistent)
@ManagedAttribute public void setReplyToDestinationSelectorName(String replyToDestinationSelectorName)
@ManagedAttribute public void setRequestTimeout(long requestTimeout)
@ManagedAttribute @Deprecated public void setSubscriptionDurable(boolean subscriptionDurable)
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public void setTemplateConnectionFactory(javax.jms.ConnectionFactory templateConnectionFactory)
@ManagedAttribute public void setTimeToLive(long timeToLive)
@ManagedAttribute public void setTransacted(boolean consumerTransacted)
@ManagedAttribute @Deprecated public void setTransactedInOut(boolean transactedInOut)
@ManagedAttribute public void setLazyCreateTransactionManager(boolean lazyCreating)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
@ManagedAttribute public void setTransactionName(String transactionName)
@ManagedAttribute public void setTransactionTimeout(int transactionTimeout)
@ManagedAttribute public void setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
public JmsMessageType getJmsMessageType()
public void setJmsMessageType(JmsMessageType jmsMessageType)
public JmsKeyFormatStrategy getJmsKeyFormatStrategy()
public void setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsHeaderStrategy)
@ManagedAttribute public boolean isTransferExchange()
@ManagedAttribute public void setTransferExchange(boolean transferExchange)
@ManagedAttribute public boolean isTransferException()
@ManagedAttribute public void setTransferException(boolean transferException)
@ManagedAttribute public boolean isTestConnectionOnStartup()
@ManagedAttribute public void setTestConnectionOnStartup(boolean testConnectionOnStartup)
@ManagedAttribute public boolean isForceSendOriginalMessage()
@ManagedAttribute public void setForceSendOriginalMessage(boolean forceSendOriginalMessage)
@ManagedAttribute public boolean isDisableTimeToLive()
@ManagedAttribute public void setDisableTimeToLive(boolean disableTimeToLive)
@ManagedAttribute public void setAsyncConsumer(boolean asyncConsumer)
@ManagedAttribute public boolean isAsyncConsumer()
@ManagedAttribute public void setAsyncStartListener(boolean asyncStartListener)
@ManagedAttribute public boolean isAsyncStartListener()
@ManagedAttribute public void setAsyncStopListener(boolean asyncStopListener)
@ManagedAttribute public boolean isAsyncStopListener()
@ManagedAttribute public boolean isAllowNullBody()
@ManagedAttribute public void setAllowNullBody(boolean allowNullBody)
@ManagedAttribute public boolean isIncludeSentJMSMessageID()
@ManagedAttribute public void setIncludeSentJMSMessageID(boolean includeSentJMSMessageID)
@ManagedAttribute public boolean isIncludeAllJMSXProperties()
@ManagedAttribute public void setIncludeAllJMSXProperties(boolean includeAllJMSXProperties)
@ManagedAttribute public DefaultTaskExecutorType getDefaultTaskExecutorType()
public void setDefaultTaskExecutorType(DefaultTaskExecutorType type)
public MessageListenerContainerFactory getMessageListenerContainerFactory()
public void setMessageListenerContainerFactory(MessageListenerContainerFactory messageListenerContainerFactory)
@ManagedAttribute public String getReplyToType()
@ManagedAttribute public void setReplyToType(String replyToType)
@ManagedAttribute(description="Camel ID") public String getCamelId()
@ManagedAttribute(description="Camel ManagementName") public String getCamelManagementName()
@ManagedAttribute(description="Endpoint Uri", mask=true) public String getEndpointUri()
getEndpointUri
in interface org.apache.camel.Endpoint
getEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
@ManagedAttribute(description="Service State") public String getState()
@ManagedAttribute(description="Number of running message listeners") public int getRunningMessageListeners()
protected String createEndpointUri()
createEndpointUri
in class org.apache.camel.impl.DefaultEndpoint
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |