|
||||||||||
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.DefaultComponent org.apache.camel.impl.UriEndpointComponent org.apache.camel.component.jms.JmsComponent
public class JmsComponent
Field Summary |
---|
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
JmsComponent()
|
|
JmsComponent(org.apache.camel.CamelContext context)
|
|
JmsComponent(JmsConfiguration configuration)
|
Method Summary | |
---|---|
protected String |
convertPathToActualDestination(String path,
Map<String,Object> parameters)
A strategy method allowing the URI destination to be translated into the actual JMS destination name (say by looking up in JNDI or something) |
protected JmsConfiguration |
createConfiguration()
Factory method to create the default configuration instance |
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters)
|
protected void |
doShutdown()
|
protected void |
doStart()
|
protected ExecutorService |
getAsyncStartStopExecutorService()
|
JmsConfiguration |
getConfiguration()
|
org.apache.camel.spi.HeaderFilterStrategy |
getHeaderFilterStrategy()
|
QueueBrowseStrategy |
getQueueBrowseStrategy()
|
static JmsComponent |
jmsComponent()
Static builder method |
static JmsComponent |
jmsComponent(javax.jms.ConnectionFactory connectionFactory)
Static builder method |
static JmsComponent |
jmsComponent(JmsConfiguration configuration)
Static builder method |
static JmsComponent |
jmsComponentAutoAcknowledge(javax.jms.ConnectionFactory connectionFactory)
Static builder method |
static JmsComponent |
jmsComponentClientAcknowledge(javax.jms.ConnectionFactory connectionFactory)
Static builder method |
static JmsComponent |
jmsComponentTransacted(javax.jms.ConnectionFactory connectionFactory)
|
static JmsComponent |
jmsComponentTransacted(javax.jms.ConnectionFactory connectionFactory,
org.springframework.transaction.PlatformTransactionManager transactionManager)
|
void |
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
|
void |
setAcknowledgementMode(int consumerAcknowledgementMode)
|
void |
setAcknowledgementModeName(String consumerAcknowledgementMode)
|
void |
setAllowNullBody(boolean allowNullBody)
|
void |
setAlwaysCopyMessage(boolean alwaysCopyMessage)
|
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
|
void |
setAsyncConsumer(boolean asyncConsumer)
|
void |
setAsyncStartListener(boolean asyncStartListener)
|
void |
setAsyncStopListener(boolean asyncStopListener)
|
void |
setAutoStartup(boolean autoStartup)
|
void |
setCacheLevel(int cacheLevel)
|
void |
setCacheLevelName(String cacheName)
|
void |
setClientId(String consumerClientId)
|
void |
setConcurrentConsumers(int concurrentConsumers)
|
void |
setConfiguration(JmsConfiguration configuration)
Sets the JMS configuration |
void |
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
|
void |
setDefaultTaskExecutorType(DefaultTaskExecutorType type)
|
void |
setDeliveryMode(Integer deliveryMode)
|
void |
setDeliveryPersistent(boolean deliveryPersistent)
|
void |
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
|
void |
setDurableSubscriptionName(String durableSubscriptionName)
|
void |
setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
|
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
|
void |
setErrorHandlerLoggingLevel(org.apache.camel.LoggingLevel errorHandlerLoggingLevel)
|
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 jmsKeyFormatStrategy)
|
void |
setJmsKeyFormatStrategy(String jmsKeyFormatStrategyName)
|
void |
setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
|
void |
setLazyCreateTransactionManager(boolean lazyCreating)
|
void |
setMapJmsMessage(boolean mapJmsMessage)
|
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 |
setPreserveMessageQos(boolean preserveMessageQos)
|
void |
setPriority(int priority)
|
void |
setPubSubNoLocal(boolean pubSubNoLocal)
|
void |
setQueueBrowseStrategy(QueueBrowseStrategy queueBrowseStrategy)
|
void |
setReceiveTimeout(long receiveTimeout)
|
void |
setRecoveryInterval(long recoveryInterval)
|
void |
setReplyToCacheLevelName(String cacheName)
|
void |
setReplyToType(ReplyToType replyToType)
|
void |
setRequestTimeout(long requestTimeout)
|
void |
setRequestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
|
void |
setSubscriptionDurable(boolean subscriptionDurable)
Deprecated. |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
|
void |
setTestConnectionOnStartup(boolean testConnectionOnStartup)
|
void |
setTimeToLive(long timeToLive)
|
void |
setTransacted(boolean consumerTransacted)
|
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.UriEndpointComponent |
---|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass |
Methods inherited from class org.apache.camel.impl.DefaultComponent |
---|
afterConfiguration, createConfiguration, createEndpoint, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JmsComponent()
public JmsComponent(org.apache.camel.CamelContext context)
public JmsComponent(JmsConfiguration configuration)
Method Detail |
---|
public static JmsComponent jmsComponent()
public static JmsComponent jmsComponent(JmsConfiguration configuration)
public static JmsComponent jmsComponent(javax.jms.ConnectionFactory connectionFactory)
public static JmsComponent jmsComponentClientAcknowledge(javax.jms.ConnectionFactory connectionFactory)
public static JmsComponent jmsComponentAutoAcknowledge(javax.jms.ConnectionFactory connectionFactory)
public static JmsComponent jmsComponentTransacted(javax.jms.ConnectionFactory connectionFactory)
public static JmsComponent jmsComponentTransacted(javax.jms.ConnectionFactory connectionFactory, org.springframework.transaction.PlatformTransactionManager transactionManager)
public JmsConfiguration getConfiguration()
public void setConfiguration(JmsConfiguration configuration)
configuration
- the configuration to use by default for endpointspublic void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
public void setAcknowledgementMode(int consumerAcknowledgementMode)
public void setEagerLoadingOfProperties(boolean eagerLoadingOfProperties)
public void setAcknowledgementModeName(String consumerAcknowledgementMode)
public void setAutoStartup(boolean autoStartup)
public void setCacheLevel(int cacheLevel)
public void setCacheLevelName(String cacheName)
public void setReplyToCacheLevelName(String cacheName)
public void setClientId(String consumerClientId)
public void setConcurrentConsumers(int concurrentConsumers)
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
public void setDeliveryPersistent(boolean deliveryPersistent)
public void setDeliveryMode(Integer deliveryMode)
public void setDurableSubscriptionName(String durableSubscriptionName)
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setErrorHandlerLoggingLevel(org.apache.camel.LoggingLevel errorHandlerLoggingLevel)
public void setErrorHandlerLogStackTrace(boolean errorHandlerLogStackTrace)
public void setExplicitQosEnabled(boolean explicitQosEnabled)
public void setExposeListenerSession(boolean exposeListenerSession)
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
public void setIdleConsumerLimit(int idleConsumerLimit)
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public void setMaxMessagesPerTask(int maxMessagesPerTask)
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
public void setMapJmsMessage(boolean mapJmsMessage)
public void setMessageIdEnabled(boolean messageIdEnabled)
public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
public void setAlwaysCopyMessage(boolean alwaysCopyMessage)
public void setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
public void setPriority(int priority)
public void setPubSubNoLocal(boolean pubSubNoLocal)
public void setReceiveTimeout(long receiveTimeout)
public void setRecoveryInterval(long recoveryInterval)
@Deprecated public void setSubscriptionDurable(boolean subscriptionDurable)
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public void setTimeToLive(long timeToLive)
public void setTransacted(boolean consumerTransacted)
public void setLazyCreateTransactionManager(boolean lazyCreating)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public void setTransactionName(String transactionName)
public void setTransactionTimeout(int transactionTimeout)
public void setTestConnectionOnStartup(boolean testConnectionOnStartup)
public void setAsyncStartListener(boolean asyncStartListener)
public void setAsyncStopListener(boolean asyncStopListener)
public void setForceSendOriginalMessage(boolean forceSendOriginalMessage)
public void setRequestTimeout(long requestTimeout)
public void setRequestTimeoutCheckerInterval(long requestTimeoutCheckerInterval)
public void setTransferExchange(boolean transferExchange)
public void setTransferException(boolean transferException)
public void setJmsOperations(org.springframework.jms.core.JmsOperations jmsOperations)
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
public void setReplyToType(ReplyToType replyToType)
public void setPreserveMessageQos(boolean preserveMessageQos)
public void setAsyncConsumer(boolean asyncConsumer)
public void setAllowNullBody(boolean allowNullBody)
public void setIncludeSentJMSMessageID(boolean includeSentJMSMessageID)
public void setIncludeAllJMSXProperties(boolean includeAllJMSXProperties)
public void setDefaultTaskExecutorType(DefaultTaskExecutorType type)
public void setJmsKeyFormatStrategy(JmsKeyFormatStrategy jmsKeyFormatStrategy)
public void setJmsKeyFormatStrategy(String jmsKeyFormatStrategyName)
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
org.springframework.beans.BeansException
public QueueBrowseStrategy getQueueBrowseStrategy()
public void setQueueBrowseStrategy(QueueBrowseStrategy queueBrowseStrategy)
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
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doShutdown() throws Exception
doShutdown
in class org.apache.camel.support.ServiceSupport
Exception
protected ExecutorService getAsyncStartStopExecutorService()
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
protected String convertPathToActualDestination(String path, Map<String,Object> parameters)
protected JmsConfiguration createConfiguration()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |