org.apache.cxf.transport.jms
Class JMSConfiguration
java.lang.Object
org.apache.cxf.transport.jms.JMSConfiguration
public class JMSConfiguration
- extends Object
Field Summary |
static int |
DEFAULT_VALUE
Default value to mark as unset |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEFAULT_VALUE
public static final int DEFAULT_VALUE
- Default value to mark as unset
- See Also:
- Constant Field Values
JMSConfiguration
public JMSConfiguration()
ensureProperlyConfigured
public void ensureProperlyConfigured()
getJndiEnvironment
public Properties getJndiEnvironment()
setJndiEnvironment
public void setJndiEnvironment(Properties jndiEnvironment)
getConnectionFactoryName
public String getConnectionFactoryName()
setConnectionFactoryName
public void setConnectionFactoryName(String connectionFactoryName)
getUserName
public String getUserName()
setUserName
public void setUserName(String userName)
getPassword
public String getPassword()
setPassword
public void setPassword(String password)
isPubSubNoLocal
public boolean isPubSubNoLocal()
setPubSubNoLocal
public void setPubSubNoLocal(boolean pubSubNoLocal)
getReceiveTimeout
public Long getReceiveTimeout()
setReceiveTimeout
public void setReceiveTimeout(Long receiveTimeout)
getServerReceiveTimeout
public Long getServerReceiveTimeout()
setServerReceiveTimeout
public void setServerReceiveTimeout(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
- 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)
getDestinationResolver
public DestinationResolver getDestinationResolver()
setDestinationResolver
public void setDestinationResolver(DestinationResolver destinationResolver)
isSessionTransacted
public boolean isSessionTransacted()
setSessionTransacted
public void setSessionTransacted(boolean sessionTransacted)
setTransactionManager
@Deprecated
public void setTransactionManager(Object transactionManager)
- Deprecated.
- For compatibility with old spring based code
- Parameters:
transactionManager
-
getMaxSuspendedContinuations
public int getMaxSuspendedContinuations()
setMaxSuspendedContinuations
public void setMaxSuspendedContinuations(int maxSuspendedContinuations)
getReconnectPercentOfMax
public int getReconnectPercentOfMax()
setReconnectPercentOfMax
public void setReconnectPercentOfMax(int reconnectPercentOfMax)
setUseConduitIdSelector
public void setUseConduitIdSelector(boolean useConduitIdSelector)
isUseConduitIdSelector
public boolean isUseConduitIdSelector()
setReconnectOnException
@Deprecated
public void setReconnectOnException(boolean reconnectOnException)
- Deprecated.
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
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()
isJmsProviderTibcoEms
public boolean isJmsProviderTibcoEms()
- Returns:
- Returns the jmsProviderTibcoEms.
setJmsProviderTibcoEms
public void setJmsProviderTibcoEms(boolean jmsProviderTibcoEms)
- Parameters:
jmsProviderTibcoEms
- The jmsProviderTibcoEms to set.
resolveOrCreateDestination
public static javax.jms.Destination resolveOrCreateDestination(javax.jms.Session session,
DestinationResolver resolver,
String replyToDestinationName,
boolean pubSubDomain)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getReplyToDestination
public javax.jms.Destination getReplyToDestination(javax.jms.Session session,
String userDestination)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getReplyDestination
public javax.jms.Destination getReplyDestination(javax.jms.Session session)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getTargetDestination
public javax.jms.Destination getTargetDestination(javax.jms.Session session)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getReplyDestination
public javax.jms.Destination getReplyDestination(javax.jms.Session session,
String replyToName)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getTransactionManager
public TransactionManager getTransactionManager()
setTransactionManager
public void setTransactionManager(TransactionManager transactionManager)
Apache CXF