org.apache.cxf.transport.jms
Class JMSConfiguration

java.lang.Object
  org.apache.cxf.transport.jms.JMSConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class JMSConfiguration
extends Object
implements org.springframework.beans.factory.InitializingBean

Field Summary

static int

DEFAULT_VALUE The use of -1 is to make easier to determine if the setCacheLevel has been called.

Constructor Summary

JMSConfiguration()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_VALUE

public static final int DEFAULT_VALUE

The use of -1 is to make easier to determine if the setCacheLevel has been called.

See Also:

Constant Field Values

Constructor Detail

JMSConfiguration

public JMSConfiguration()

Method Detail

ensureProperlyConfigured

public void ensureProperlyConfigured(Message msg)

getCacheLevelName

public String getCacheLevelName()

setCacheLevelName

public void setCacheLevelName(String cacheLevelName)

getCacheLevel

public int getCacheLevel()

setCacheLevel

public void setCacheLevel(int cacheLevel)

getRecoveryInterval

public long getRecoveryInterval()

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

isAutoResolveDestination

public boolean isAutoResolveDestination()

setAutoResolveDestination

public void setAutoResolveDestination(boolean autoResolveDestination)

isUsingEndpointInfo

public boolean isUsingEndpointInfo()

setUsingEndpointInfo

public void setUsingEndpointInfo(boolean usingEndpointInfo)

isMessageIdEnabled

public boolean isMessageIdEnabled()

setMessageIdEnabled

public void setMessageIdEnabled(boolean messageIdEnabled)

isMessageTimestampEnabled

public boolean isMessageTimestampEnabled()

setMessageTimestampEnabled

public void setMessageTimestampEnabled(boolean messageTimestampEnabled)

isPubSubNoLocal

public boolean isPubSubNoLocal()

setPubSubNoLocal

public void setPubSubNoLocal(boolean pubSubNoLocal)

getReceiveTimeout

public Long getReceiveTimeout()

setReceiveTimeout

public void setReceiveTimeout(Long receiveTimeout)

isExplicitQosEnabled

public boolean isExplicitQosEnabled()

setExplicitQosEnabled

public void setExplicitQosEnabled(boolean explicitQosEnabled)

getDeliveryMode

public int getDeliveryMode()

setDeliveryMode

public void setDeliveryMode(int deliveryMode)

getPriority

public int getPriority()

setPriority

public void setPriority(int priority)

getTimeToLive

public long getTimeToLive()

setTimeToLive

public void setTimeToLive(long timeToLive)

getMessageSelector

public String getMessageSelector()

setMessageSelector

public void setMessageSelector(String messageSelector)

setConduitSelectorPrefix

public void setConduitSelectorPrefix(String conduitSelectorPrefix)

getConduitSelectorPrefix

public String getConduitSelectorPrefix()

isSetConduitSelectorPrefix

public boolean isSetConduitSelectorPrefix()

isSubscriptionDurable

public boolean isSubscriptionDurable()

setSubscriptionDurable

public void setSubscriptionDurable(boolean subscriptionDurable)

getDurableSubscriptionName

public String getDurableSubscriptionName()

setDurableSubscriptionName

public void setDurableSubscriptionName(String durableSubscriptionName)

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

getTargetDestination

public String getTargetDestination()

setTargetDestination

public void setTargetDestination(String targetDestination)

getReplyDestination

public String getReplyDestination()

setReplyDestination

public void setReplyDestination(String replyDestination)

getReplyToDestination

public String getReplyToDestination()

setReplyToDestination

public void setReplyToDestination(String replyToDestination)

getMessageType

public String getMessageType()

setMessageType

public void setMessageType(String messageType)

isPubSubDomain

public boolean isPubSubDomain()

setPubSubDomain

public void setPubSubDomain(boolean pubSubDomain)

isReplyPubSubDomain

public boolean isReplyPubSubDomain()

setReplyPubSubDomain

public void setReplyPubSubDomain(boolean replyPubSubDomain)

isUseJms11

public boolean isUseJms11()

setUseJms11

public void setUseJms11(boolean useJms11)

getDestinationResolver

public org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()

setDestinationResolver

public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)

isSessionTransacted

public boolean isSessionTransacted()

setSessionTransacted

public void setSessionTransacted(boolean sessionTransacted)

getTransactionManager

public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

getConcurrentConsumers

public int getConcurrentConsumers()

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

getMaxConcurrentConsumers

public int getMaxConcurrentConsumers()

setMaxConcurrentConsumers

public void setMaxConcurrentConsumers(int maxConcurrentConsumers)

getMaxSuspendedContinuations

public int getMaxSuspendedContinuations()

setMaxSuspendedContinuations

public void setMaxSuspendedContinuations(int maxSuspendedContinuations)

getReconnectPercentOfMax

public int getReconnectPercentOfMax()

setReconnectPercentOfMax

public void setReconnectPercentOfMax(int reconnectPercentOfMax)

getTaskExecutor

public org.springframework.core.task.TaskExecutor getTaskExecutor()

setTaskExecutor

public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

setUseConduitIdSelector

public void setUseConduitIdSelector(boolean useConduitIdSelector)

isUseConduitIdSelector

public boolean isUseConduitIdSelector()

isSetUseConduitIdSelector

public boolean isSetUseConduitIdSelector()

setJndiTemplate

public void setJndiTemplate(org.springframework.jndi.JndiTemplate jndiTemplate)

getJndiTemplate

public org.springframework.jndi.JndiTemplate getJndiTemplate()

getJndiConfig

public JNDIConfiguration getJndiConfig()

setJndiConfig

public void setJndiConfig(JNDIConfiguration jndiConfig)

isReconnectOnException

public boolean isReconnectOnException()

setReconnectOnException

public void setReconnectOnException(boolean reconnectOnException)

isAcceptMessagesWhileStopping

public boolean isAcceptMessagesWhileStopping()

setAcceptMessagesWhileStopping

public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)

getOrCreateWrappedConnectionFactory

public javax.jms.ConnectionFactory getOrCreateWrappedConnectionFactory()

Tries to creates a ConnectionFactory from jndi if none was set as a property by using the jndConfig. Then it determines if the connectionFactory should be wrapped into a SingleConnectionFactory and wraps it if necessary. After the first call the same connectionFactory will be returned for all subsequent calls

Returns:

usable connectionFactory

getWrappedConnectionFactory

public javax.jms.ConnectionFactory getWrappedConnectionFactory()

destroyWrappedConnectionFactory

public void destroyWrappedConnectionFactory()

getConnectionFactory

protected javax.jms.ConnectionFactory getConnectionFactory()

Only for tests

Returns:

isWrapInSingleConnectionFactory

public boolean isWrapInSingleConnectionFactory()

setWrapInSingleConnectionFactory

public void setWrapInSingleConnectionFactory(boolean wrapInSingleConnectionFactory)

getDurableSubscriptionClientId

public String getDurableSubscriptionClientId()

setDurableSubscriptionClientId

public void setDurableSubscriptionClientId(String durableSubscriptionClientId)

setTargetService

public void setTargetService(String targetService)

getTargetService

public String getTargetService()

setRequestURI

public void setRequestURI(String requestURI)

getRequestURI

public String getRequestURI()

isEnforceSpec

public boolean isEnforceSpec()

setEnforceSpec

public void setEnforceSpec(boolean enforceSpec)

isSetEnforceSpec

public boolean isSetEnforceSpec()

setJmsTemplate

public void setJmsTemplate(org.springframework.jms.core.JmsTemplate jmsTemplate)

getJmsTemplate

public org.springframework.jms.core.JmsTemplate getJmsTemplate()

getMessageListenerContainer

public org.springframework.jms.listener.AbstractMessageListenerContainer getMessageListenerContainer()

setMessageListenerContainer

public void setMessageListenerContainer(org.springframework.jms.listener.AbstractMessageListenerContainer messageListenerContainer)

isJmsProviderTibcoEms

public boolean isJmsProviderTibcoEms()

Returns:

Returns the jmsProviderTibcoEms.

setJmsProviderTibcoEms

public void setJmsProviderTibcoEms(boolean jmsProviderTibcoEms)

Parameters:

jmsProviderTibcoEms - The jmsProviderTibcoEms to set.