|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.component.jms.JmsConfiguration
public class JmsConfiguration
Field Summary | |
---|---|
protected static String |
AUTO_ACKNOWLEDGE
|
protected static String |
CLIENT_ACKNOWLEDGE
|
protected static String |
DUPS_OK_ACKNOWLEDGE
|
protected static String |
TRANSACTED
|
Constructor Summary | |
---|---|
JmsConfiguration()
|
|
JmsConfiguration(ConnectionFactory connectionFactory)
|
Method Summary | |
---|---|
protected org.springframework.jms.listener.AbstractMessageListenerContainer |
chooseMessageListenerContainerImplementation()
|
protected void |
configureMessageListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer container)
|
JmsConfiguration |
copy()
Returns a copy of this configuration |
protected ConnectionFactory |
createConnectionFactory()
Factory method which allows derived classes to customize the lazy creation |
org.springframework.jms.core.JmsOperations |
createJmsOperations(boolean pubSubDomain,
String destination)
|
protected ConnectionFactory |
createListenerConnectionFactory()
Factory method which allows derived classes to customize the lazy creation |
org.springframework.jms.listener.AbstractMessageListenerContainer |
createMessageListenerContainer()
|
protected ConnectionFactory |
createTemplateConnectionFactory()
Factory method which allows derived classes to customize the lazy creation |
int |
getAcknowledgementMode()
|
String |
getAcknowledgementModeName()
|
int |
getCacheLevel()
|
String |
getCacheLevelName()
|
String |
getClientId()
|
int |
getConcurrentConsumers()
|
ConnectionFactory |
getConnectionFactory()
|
ConsumerType |
getConsumerType()
|
String |
getDurableSubscriptionName()
|
ExceptionListener |
getExceptionListener()
|
int |
getIdleTaskExecutionLimit()
|
ConnectionFactory |
getListenerConnectionFactory()
|
int |
getMaxConcurrentConsumers()
|
int |
getMaxMessagesPerTask()
|
org.springframework.jms.support.converter.MessageConverter |
getMessageConverter()
|
int |
getPriority()
|
long |
getReceiveTimeout()
|
long |
getRecoveryInterval()
|
org.springframework.jms.listener.serversession.ServerSessionFactory |
getServerSessionFactory()
|
org.springframework.core.task.TaskExecutor |
getTaskExecutor()
|
ConnectionFactory |
getTemplateConnectionFactory()
|
long |
getTimeToLive()
|
org.springframework.transaction.PlatformTransactionManager |
getTransactionManager()
|
String |
getTransactionName()
|
int |
getTransactionTimeout()
|
boolean |
isAcceptMessagesWhileStopping()
|
boolean |
isAutoStartup()
|
boolean |
isDeliveryPersistent()
|
boolean |
isExplicitQosEnabled()
|
boolean |
isExposeListenerSession()
|
boolean |
isMessageIdEnabled()
|
boolean |
isMessageTimestampEnabled()
|
boolean |
isPubSubNoLocal()
|
boolean |
isSubscriptionDurable()
|
boolean |
isTransacted()
|
boolean |
isUseVersion102()
|
void |
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
|
void |
setAcknowledgementMode(int consumerAcknowledgementMode)
|
void |
setAcknowledgementModeName(String consumerAcknowledgementMode)
|
void |
setAutoStartup(boolean autoStartup)
|
void |
setCacheLevel(int cacheLevel)
|
void |
setCacheLevelName(String cacheName)
|
void |
setClientId(String consumerClientId)
|
void |
setConcurrentConsumers(int concurrentConsumers)
|
void |
setConnectionFactory(ConnectionFactory connectionFactory)
Sets the default connection factory to be used if a connection factory is not specified for either setTemplateConnectionFactory(ConnectionFactory) or
setListenerConnectionFactory(ConnectionFactory) |
void |
setConsumerType(ConsumerType consumerType)
|
void |
setDeliveryPersistent(boolean deliveryPersistent)
|
void |
setDurableSubscriptionName(String durableSubscriptionName)
|
void |
setExceptionListener(ExceptionListener exceptionListener)
|
void |
setExplicitQosEnabled(boolean explicitQosEnabled)
|
void |
setExposeListenerSession(boolean exposeListenerSession)
|
void |
setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
|
void |
setListenerConnectionFactory(ConnectionFactory listenerConnectionFactory)
Sets the connection factory to be used for consuming messages via the createMessageListenerContainer() |
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 |
setPriority(int priority)
|
void |
setPubSubNoLocal(boolean pubSubNoLocal)
|
void |
setReceiveTimeout(long receiveTimeout)
|
void |
setRecoveryInterval(long recoveryInterval)
|
void |
setServerSessionFactory(org.springframework.jms.listener.serversession.ServerSessionFactory serverSessionFactory)
|
void |
setSubscriptionDurable(boolean subscriptionDurable)
|
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
|
void |
setTemplateConnectionFactory(ConnectionFactory templateConnectionFactory)
Sets the connection factory to be used for sending messages via the JmsTemplate via createJmsOperations(boolean, String) |
void |
setTimeToLive(long timeToLive)
|
void |
setTransacted(boolean consumerTransacted)
|
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
|
void |
setTransactionName(String transactionName)
|
void |
setTransactionTimeout(int transactionTimeout)
|
void |
setUseVersion102(boolean useVersion102)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final String TRANSACTED
protected static final String CLIENT_ACKNOWLEDGE
protected static final String AUTO_ACKNOWLEDGE
protected static final String DUPS_OK_ACKNOWLEDGE
Constructor Detail |
---|
public JmsConfiguration()
public JmsConfiguration(ConnectionFactory connectionFactory)
Method Detail |
---|
public JmsConfiguration copy()
public org.springframework.jms.core.JmsOperations createJmsOperations(boolean pubSubDomain, String destination)
public org.springframework.jms.listener.AbstractMessageListenerContainer createMessageListenerContainer()
protected void configureMessageListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer container)
public ConnectionFactory getConnectionFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
setTemplateConnectionFactory(ConnectionFactory)
or
setListenerConnectionFactory(ConnectionFactory)
connectionFactory
- the default connection factory to usepublic ConnectionFactory getListenerConnectionFactory()
public void setListenerConnectionFactory(ConnectionFactory listenerConnectionFactory)
createMessageListenerContainer()
listenerConnectionFactory
- the connection factory to use for
consuming messagespublic ConnectionFactory getTemplateConnectionFactory()
public void setTemplateConnectionFactory(ConnectionFactory templateConnectionFactory)
JmsTemplate
via createJmsOperations(boolean, String)
templateConnectionFactory
- the connection factory for sending
messagespublic boolean isUseVersion102()
public void setUseVersion102(boolean useVersion102)
public boolean isAutoStartup()
public void setAutoStartup(boolean autoStartup)
public boolean isAcceptMessagesWhileStopping()
public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
public String getClientId()
public void setClientId(String consumerClientId)
public String getDurableSubscriptionName()
public void setDurableSubscriptionName(String durableSubscriptionName)
public ExceptionListener getExceptionListener()
public void setExceptionListener(ExceptionListener exceptionListener)
public boolean isSubscriptionDurable()
public void setSubscriptionDurable(boolean subscriptionDurable)
public String getAcknowledgementModeName()
public void setAcknowledgementModeName(String consumerAcknowledgementMode)
public boolean isExposeListenerSession()
public void setExposeListenerSession(boolean exposeListenerSession)
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public boolean isPubSubNoLocal()
public void setPubSubNoLocal(boolean pubSubNoLocal)
public int getConcurrentConsumers()
public void setConcurrentConsumers(int concurrentConsumers)
public int getMaxMessagesPerTask()
public void setMaxMessagesPerTask(int maxMessagesPerTask)
public org.springframework.jms.listener.serversession.ServerSessionFactory getServerSessionFactory()
public void setServerSessionFactory(org.springframework.jms.listener.serversession.ServerSessionFactory serverSessionFactory)
public int getCacheLevel()
public void setCacheLevel(int cacheLevel)
public String getCacheLevelName()
public void setCacheLevelName(String cacheName)
public long getRecoveryInterval()
public void setRecoveryInterval(long recoveryInterval)
public long getReceiveTimeout()
public void setReceiveTimeout(long receiveTimeout)
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public String getTransactionName()
public void setTransactionName(String transactionName)
public int getTransactionTimeout()
public void setTransactionTimeout(int transactionTimeout)
public int getIdleTaskExecutionLimit()
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
public int getMaxConcurrentConsumers()
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public boolean isExplicitQosEnabled()
public void setExplicitQosEnabled(boolean explicitQosEnabled)
public boolean isDeliveryPersistent()
public void setDeliveryPersistent(boolean deliveryPersistent)
public long getTimeToLive()
public void setTimeToLive(long timeToLive)
public org.springframework.jms.support.converter.MessageConverter getMessageConverter()
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter messageConverter)
public boolean isMessageIdEnabled()
public void setMessageIdEnabled(boolean messageIdEnabled)
public boolean isMessageTimestampEnabled()
public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
public int getPriority()
public void setPriority(int priority)
public ConsumerType getConsumerType()
public void setConsumerType(ConsumerType consumerType)
public int getAcknowledgementMode()
public void setAcknowledgementMode(int consumerAcknowledgementMode)
public boolean isTransacted()
public void setTransacted(boolean consumerTransacted)
protected org.springframework.jms.listener.AbstractMessageListenerContainer chooseMessageListenerContainerImplementation()
protected ConnectionFactory createConnectionFactory()
protected ConnectionFactory createListenerConnectionFactory()
protected ConnectionFactory createTemplateConnectionFactory()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |