public class JMSConfiguration extends Object implements org.springframework.beans.factory.InitializingBean
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_VALUE
The use of -1 is to make easier to determine
if the setCacheLevel has been called.
|
Constructor and Description |
---|
JMSConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
void |
destroyWrappedConnectionFactory() |
void |
ensureProperlyConfigured(Message msg) |
int |
getCacheLevel() |
String |
getCacheLevelName() |
int |
getConcurrentConsumers() |
String |
getConduitSelectorPrefix() |
protected javax.jms.ConnectionFactory |
getConnectionFactory()
Only for tests
|
int |
getDeliveryMode() |
org.springframework.jms.support.destination.DestinationResolver |
getDestinationResolver() |
String |
getDurableSubscriptionClientId() |
String |
getDurableSubscriptionName() |
org.springframework.jms.core.JmsTemplate |
getJmsTemplate() |
JNDIConfiguration |
getJndiConfig() |
org.springframework.jndi.JndiTemplate |
getJndiTemplate() |
int |
getMaxConcurrentConsumers() |
int |
getMaxSuspendedContinuations() |
org.springframework.jms.listener.AbstractMessageListenerContainer |
getMessageListenerContainer() |
String |
getMessageSelector() |
String |
getMessageType() |
javax.jms.ConnectionFactory |
getOrCreateWrappedConnectionFactory()
Tries to creates a ConnectionFactory from jndi if none was set as a property
by using the jndConfig.
|
int |
getPriority() |
Long |
getReceiveTimeout() |
int |
getReconnectPercentOfMax() |
long |
getRecoveryInterval() |
String |
getReplyDestination() |
String |
getReplyToDestination() |
String |
getRequestURI() |
Long |
getServerReceiveTimeout() |
String |
getTargetDestination() |
String |
getTargetService() |
org.springframework.core.task.TaskExecutor |
getTaskExecutor() |
long |
getTimeToLive() |
org.springframework.transaction.PlatformTransactionManager |
getTransactionManager() |
javax.jms.ConnectionFactory |
getWrappedConnectionFactory() |
boolean |
isAcceptMessagesWhileStopping() |
boolean |
isAutoResolveDestination() |
boolean |
isEnforceSpec() |
boolean |
isExplicitQosEnabled() |
boolean |
isJmsProviderTibcoEms() |
boolean |
isMessageIdEnabled() |
boolean |
isMessageTimestampEnabled() |
boolean |
isPubSubDomain() |
boolean |
isPubSubNoLocal() |
boolean |
isReconnectOnException() |
boolean |
isReplyPubSubDomain() |
boolean |
isSessionTransacted() |
boolean |
isSetConduitSelectorPrefix() |
boolean |
isSetEnforceSpec() |
boolean |
isSetUseConduitIdSelector() |
boolean |
isSubscriptionDurable() |
boolean |
isUseConduitIdSelector() |
boolean |
isUseJms11() |
boolean |
isUsingEndpointInfo() |
boolean |
isWrapInSingleConnectionFactory() |
void |
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping) |
void |
setAutoResolveDestination(boolean autoResolveDestination) |
void |
setCacheLevel(int cacheLevel) |
void |
setCacheLevelName(String cacheLevelName) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConduitSelectorPrefix(String conduitSelectorPrefix) |
void |
setConnectionFactory(javax.jms.ConnectionFactory connectionFactory) |
void |
setDeliveryMode(int deliveryMode) |
void |
setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver) |
void |
setDurableSubscriptionClientId(String durableSubscriptionClientId) |
void |
setDurableSubscriptionName(String durableSubscriptionName) |
void |
setEnforceSpec(boolean enforceSpec) |
void |
setExplicitQosEnabled(boolean explicitQosEnabled) |
void |
setJmsProviderTibcoEms(boolean jmsProviderTibcoEms) |
void |
setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate) |
void |
setJndiConfig(JNDIConfiguration jndiConfig) |
void |
setJndiTemplate(org.springframework.jndi.JndiTemplate jndiTemplate) |
void |
setMaxConcurrentConsumers(int maxConcurrentConsumers) |
void |
setMaxSuspendedContinuations(int maxSuspendedContinuations) |
void |
setMessageIdEnabled(boolean messageIdEnabled) |
void |
setMessageListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer messageListenerContainer) |
void |
setMessageSelector(String messageSelector) |
void |
setMessageTimestampEnabled(boolean messageTimestampEnabled) |
void |
setMessageType(String messageType) |
void |
setPriority(int priority) |
void |
setPubSubDomain(boolean pubSubDomain) |
void |
setPubSubNoLocal(boolean pubSubNoLocal) |
void |
setReceiveTimeout(Long receiveTimeout) |
void |
setReconnectOnException(boolean reconnectOnException) |
void |
setReconnectPercentOfMax(int reconnectPercentOfMax) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setReplyDestination(String replyDestination) |
void |
setReplyPubSubDomain(boolean replyPubSubDomain) |
void |
setReplyToDestination(String replyToDestination) |
void |
setRequestURI(String requestURI) |
void |
setServerReceiveTimeout(Long receiveTimeout) |
void |
setSessionTransacted(boolean sessionTransacted) |
void |
setSubscriptionDurable(boolean subscriptionDurable) |
void |
setTargetDestination(String targetDestination) |
void |
setTargetService(String targetService) |
void |
setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) |
void |
setTimeToLive(long timeToLive) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void |
setUseConduitIdSelector(boolean useConduitIdSelector) |
void |
setUseJms11(boolean useJms11) |
void |
setUsingEndpointInfo(boolean usingEndpointInfo) |
void |
setWrapInSingleConnectionFactory(boolean wrapInSingleConnectionFactory) |
public static final int DEFAULT_VALUE
public void ensureProperlyConfigured(Message msg)
public String getCacheLevelName()
public void setCacheLevelName(String cacheLevelName)
public int getCacheLevel()
public void setCacheLevel(int cacheLevel)
public long getRecoveryInterval()
public void setRecoveryInterval(long recoveryInterval)
public boolean isAutoResolveDestination()
public void setAutoResolveDestination(boolean autoResolveDestination)
public boolean isUsingEndpointInfo()
public void setUsingEndpointInfo(boolean usingEndpointInfo)
public boolean isMessageIdEnabled()
public void setMessageIdEnabled(boolean messageIdEnabled)
public boolean isMessageTimestampEnabled()
public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
public boolean isPubSubNoLocal()
public void setPubSubNoLocal(boolean pubSubNoLocal)
public Long getReceiveTimeout()
public void setReceiveTimeout(Long receiveTimeout)
public Long getServerReceiveTimeout()
public void setServerReceiveTimeout(Long receiveTimeout)
public boolean isExplicitQosEnabled()
public void setExplicitQosEnabled(boolean explicitQosEnabled)
public int getDeliveryMode()
public void setDeliveryMode(int deliveryMode)
public int getPriority()
public void setPriority(int priority)
public long getTimeToLive()
public void setTimeToLive(long timeToLive)
public String getMessageSelector()
public void setMessageSelector(String messageSelector)
public void setConduitSelectorPrefix(String conduitSelectorPrefix)
public String getConduitSelectorPrefix()
public boolean isSetConduitSelectorPrefix()
public boolean isSubscriptionDurable()
public void setSubscriptionDurable(boolean subscriptionDurable)
public String getDurableSubscriptionName()
public void setDurableSubscriptionName(String durableSubscriptionName)
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
public String getTargetDestination()
public void setTargetDestination(String targetDestination)
public String getReplyDestination()
public void setReplyDestination(String replyDestination)
public String getReplyToDestination()
public void setReplyToDestination(String replyToDestination)
public String getMessageType()
public void setMessageType(String messageType)
public boolean isPubSubDomain()
public void setPubSubDomain(boolean pubSubDomain)
public boolean isReplyPubSubDomain()
public void setReplyPubSubDomain(boolean replyPubSubDomain)
public boolean isUseJms11()
public void setUseJms11(boolean useJms11)
public org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
public boolean isSessionTransacted()
public void setSessionTransacted(boolean sessionTransacted)
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public int getConcurrentConsumers()
public void setConcurrentConsumers(int concurrentConsumers)
public int getMaxConcurrentConsumers()
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public int getMaxSuspendedContinuations()
public void setMaxSuspendedContinuations(int maxSuspendedContinuations)
public int getReconnectPercentOfMax()
public void setReconnectPercentOfMax(int reconnectPercentOfMax)
public org.springframework.core.task.TaskExecutor getTaskExecutor()
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
public void setUseConduitIdSelector(boolean useConduitIdSelector)
public boolean isUseConduitIdSelector()
public boolean isSetUseConduitIdSelector()
public void setJndiTemplate(org.springframework.jndi.JndiTemplate jndiTemplate)
public org.springframework.jndi.JndiTemplate getJndiTemplate()
public JNDIConfiguration getJndiConfig()
public void setJndiConfig(JNDIConfiguration jndiConfig)
public boolean isReconnectOnException()
public void setReconnectOnException(boolean reconnectOnException)
public boolean isAcceptMessagesWhileStopping()
public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
public javax.jms.ConnectionFactory getOrCreateWrappedConnectionFactory()
public javax.jms.ConnectionFactory getWrappedConnectionFactory()
public void destroyWrappedConnectionFactory()
protected javax.jms.ConnectionFactory getConnectionFactory()
public boolean isWrapInSingleConnectionFactory()
public void setWrapInSingleConnectionFactory(boolean wrapInSingleConnectionFactory)
public String getDurableSubscriptionClientId()
public void setDurableSubscriptionClientId(String durableSubscriptionClientId)
public void setTargetService(String targetService)
public String getTargetService()
public void setRequestURI(String requestURI)
public String getRequestURI()
public boolean isEnforceSpec()
public void setEnforceSpec(boolean enforceSpec)
public boolean isSetEnforceSpec()
public void setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)
public org.springframework.jms.core.JmsTemplate getJmsTemplate()
public org.springframework.jms.listener.AbstractMessageListenerContainer getMessageListenerContainer()
public void setMessageListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer messageListenerContainer)
public boolean isJmsProviderTibcoEms()
public void setJmsProviderTibcoEms(boolean jmsProviderTibcoEms)
jmsProviderTibcoEms
- The jmsProviderTibcoEms to set.Apache CXF