org.apache.cxf.transport.jms
Class JMSConfiguration

java.lang.Object
  extended by org.apache.cxf.transport.jms.JMSConfiguration
All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean

public class JMSConfiguration
extends java.lang.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()
           
 java.lang.String getCacheLevelName()
           
 int getConcurrentConsumers()
           
 java.lang.String getConduitSelectorPrefix()
           
protected  javax.jms.ConnectionFactory getConnectionFactory()
          Only for tests
 int getDeliveryMode()
           
 org.springframework.jms.support.destination.DestinationResolver getDestinationResolver()
           
 java.lang.String getDurableSubscriptionClientId()
           
 java.lang.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()
           
 java.lang.String getMessageSelector()
           
 java.lang.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()
           
 java.lang.Long getReceiveTimeout()
           
 int getReconnectPercentOfMax()
           
 long getRecoveryInterval()
           
 java.lang.String getReplyDestination()
           
 java.lang.String getReplyToDestination()
           
 java.lang.String getTargetDestination()
           
 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 isMessageIdEnabled()
           
 boolean isMessageTimestampEnabled()
           
 boolean isPubSubDomain()
           
 boolean isPubSubNoLocal()
           
 boolean isReconnectOnException()
           
 boolean isSessionTransacted()
           
 boolean isSetUseConduitIdSelector()
           
 boolean isSubscriptionDurable()
           
 boolean isUseConduitIdSelector()
           
 boolean isUseJms11()
           
 boolean isUseMessageIDAsCorrelationID()
           
 boolean isUsingEndpointInfo()
           
 boolean isWrapInSingleConnectionFactory()
           
 void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
           
 void setAutoResolveDestination(boolean autoResolveDestination)
           
 void setCacheLevel(int cacheLevel)
           
 void setCacheLevelName(java.lang.String cacheLevelName)
           
 void setConcurrentConsumers(int concurrentConsumers)
           
 void setConduitSelectorPrefix(java.lang.String conduitSelectorPrefix)
           
 void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
           
 void setDeliveryMode(int deliveryMode)
           
 void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver destinationResolver)
           
 void setDurableSubscriptionClientId(java.lang.String durableSubscriptionClientId)
           
 void setDurableSubscriptionName(java.lang.String durableSubscriptionName)
           
 void setEnforceSpec(boolean enforceSpec)
           
 void setExplicitQosEnabled(boolean explicitQosEnabled)
           
 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(java.lang.String messageSelector)
           
 void setMessageTimestampEnabled(boolean messageTimestampEnabled)
           
 void setMessageType(java.lang.String messageType)
           
 void setPriority(int priority)
           
 void setPubSubDomain(boolean pubSubDomain)
           
 void setPubSubNoLocal(boolean pubSubNoLocal)
           
 void setReceiveTimeout(java.lang.Long receiveTimeout)
           
 void setReconnectOnException(boolean reconnectOnException)
           
 void setReconnectPercentOfMax(int reconnectPercentOfMax)
           
 void setRecoveryInterval(long recoveryInterval)
           
 void setReplyDestination(java.lang.String replyDestination)
           
 void setReplyToDestination(java.lang.String replyToDestination)
           
 void setSessionTransacted(boolean sessionTransacted)
           
 void setSubscriptionDurable(boolean subscriptionDurable)
           
 void setTargetDestination(java.lang.String targetDestination)
           
 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 setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)
           
 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 java.lang.String getCacheLevelName()

setCacheLevelName

public void setCacheLevelName(java.lang.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 java.lang.Long getReceiveTimeout()

setReceiveTimeout

public void setReceiveTimeout(java.lang.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 java.lang.String getMessageSelector()

setMessageSelector

public void setMessageSelector(java.lang.String messageSelector)

setConduitSelectorPrefix

public void setConduitSelectorPrefix(java.lang.String conduitSelectorPrefix)

getConduitSelectorPrefix

public java.lang.String getConduitSelectorPrefix()

isSubscriptionDurable

public boolean isSubscriptionDurable()

setSubscriptionDurable

public void setSubscriptionDurable(boolean subscriptionDurable)

getDurableSubscriptionName

public java.lang.String getDurableSubscriptionName()

setDurableSubscriptionName

public void setDurableSubscriptionName(java.lang.String durableSubscriptionName)

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception
Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
Throws:
java.lang.Exception

setConnectionFactory

public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)

getTargetDestination

public java.lang.String getTargetDestination()

setTargetDestination

public void setTargetDestination(java.lang.String targetDestination)

getReplyDestination

public java.lang.String getReplyDestination()

setReplyDestination

public void setReplyDestination(java.lang.String replyDestination)

getReplyToDestination

public java.lang.String getReplyToDestination()

setReplyToDestination

public void setReplyToDestination(java.lang.String replyToDestination)

getMessageType

public java.lang.String getMessageType()

setMessageType

public void setMessageType(java.lang.String messageType)

isPubSubDomain

public boolean isPubSubDomain()

setPubSubDomain

public void setPubSubDomain(boolean pubSubDomain)

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 determiens 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 java.lang.String getDurableSubscriptionClientId()

setDurableSubscriptionClientId

public void setDurableSubscriptionClientId(java.lang.String durableSubscriptionClientId)

isEnforceSpec

public boolean isEnforceSpec()

setEnforceSpec

public void setEnforceSpec(boolean enforceSpec)

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)

isUseMessageIDAsCorrelationID

public boolean isUseMessageIDAsCorrelationID()

setUseMessageIDAsCorrelationID

public void setUseMessageIDAsCorrelationID(boolean useMessageIDAsCorrelationID)


Apache CXF