Package org.apache.activemq
Class ActiveMQXAConnectionFactory
- java.lang.Object
-
- org.apache.activemq.jndi.JNDIBaseStorable
-
- org.apache.activemq.ActiveMQConnectionFactory
-
- org.apache.activemq.ActiveMQXAConnectionFactory
-
- All Implemented Interfaces:
Externalizable
,Serializable
,Cloneable
,ConnectionFactory
,QueueConnectionFactory
,TopicConnectionFactory
,XAConnectionFactory
,XAQueueConnectionFactory
,XATopicConnectionFactory
,Referenceable
,JNDIStorableInterface
,StatsCapable
- Direct Known Subclasses:
ActiveMQXAConnectionFactory
public class ActiveMQXAConnectionFactory extends ActiveMQConnectionFactory implements XAConnectionFactory, XAQueueConnectionFactory, XATopicConnectionFactory
A factory ofXAConnection
instances- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.ActiveMQConnectionFactory
alwaysSessionAsync, brokerURL, clientID, DEFAULT_BROKER_BIND_URL, DEFAULT_BROKER_URL, DEFAULT_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName, xaAckMode
-
-
Constructor Summary
Constructors Constructor Description ActiveMQXAConnectionFactory()
ActiveMQXAConnectionFactory(String brokerURL)
ActiveMQXAConnectionFactory(String userName, String password, String brokerURL)
ActiveMQXAConnectionFactory(String userName, String password, URI brokerURL)
ActiveMQXAConnectionFactory(URI brokerURL)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ActiveMQConnection
createActiveMQConnection(Transport transport, JMSStatsImpl stats)
XAConnection
createXAConnection()
XAConnection
createXAConnection(String userName, String password)
XAQueueConnection
createXAQueueConnection()
XAQueueConnection
createXAQueueConnection(String userName, String password)
XATopicConnection
createXATopicConnection()
XATopicConnection
createXATopicConnection(String userName, String password)
int
getXaAckMode()
void
populateProperties(Properties props)
Initialize the instance from properties stored in JNDIvoid
setXaAckMode(int xaAckMode)
-
Methods inherited from class org.apache.activemq.ActiveMQConnectionFactory
buildFromMap, buildFromProperties, configureConnection, copy, createActiveMQConnection, createActiveMQConnection, createConnection, createConnection, createQueueConnection, createQueueConnection, createTopicConnection, createTopicConnection, createTransport, getAuditDepth, getAuditMaximumProducerNumber, getBlobTransferPolicy, getBrokerURL, getClientID, getClientIdGenerator, getClientIDPrefix, getClientInternalExceptionListener, getCloseTimeout, getConnectionIdGenerator, getConnectResponseTimeout, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getMaxThreadPoolSize, getOptimizeAcknowledgeTimeOut, getOptimizedAckScheduledAckInterval, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getRedeliveryPolicyMap, getRejectedTaskHandler, getSendTimeout, getSessionTaskRunner, getStats, getTransformer, getTransportListener, getTrustedPackages, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isConsumerExpiryCheckEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isRmIdFromConnectionId, isSendAcksAsync, isStatsEnabled, isTransactedIndividualAck, isTrustAllPackages, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setCheckForDuplicates, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConnectionIdGenerator, setConnectionIDPrefix, setConnectResponseTimeout, setConsumerExpiryCheckEnabled, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMaxThreadPoolSize, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedAckScheduledAckInterval, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setRedeliveryPolicyMap, setRejectedTaskHandler, setRmIdFromConnectionId, setSendAcksAsync, setSendTimeout, setSessionTaskRunner, setStatsEnabled, setTransactedIndividualAck, setTransformer, setTransportListener, setTrustAllPackages, setTrustedPackages, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories
-
Methods inherited from class org.apache.activemq.jndi.JNDIBaseStorable
getProperties, getReference, readExternal, setProperties, writeExternal
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface javax.jms.ConnectionFactory
createConnection, createConnection
-
Methods inherited from interface javax.jms.QueueConnectionFactory
createQueueConnection, createQueueConnection
-
Methods inherited from interface javax.jms.TopicConnectionFactory
createTopicConnection, createTopicConnection
-
-
-
-
Constructor Detail
-
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory()
-
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(String userName, String password, String brokerURL)
-
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(String userName, String password, URI brokerURL)
-
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(String brokerURL)
-
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(URI brokerURL)
-
-
Method Detail
-
createXAConnection
public XAConnection createXAConnection() throws JMSException
- Specified by:
createXAConnection
in interfaceXAConnectionFactory
- Throws:
JMSException
-
createXAConnection
public XAConnection createXAConnection(String userName, String password) throws JMSException
- Specified by:
createXAConnection
in interfaceXAConnectionFactory
- Throws:
JMSException
-
createXAQueueConnection
public XAQueueConnection createXAQueueConnection() throws JMSException
- Specified by:
createXAQueueConnection
in interfaceXAQueueConnectionFactory
- Throws:
JMSException
-
createXAQueueConnection
public XAQueueConnection createXAQueueConnection(String userName, String password) throws JMSException
- Specified by:
createXAQueueConnection
in interfaceXAQueueConnectionFactory
- Throws:
JMSException
-
createXATopicConnection
public XATopicConnection createXATopicConnection() throws JMSException
- Specified by:
createXATopicConnection
in interfaceXATopicConnectionFactory
- Throws:
JMSException
-
createXATopicConnection
public XATopicConnection createXATopicConnection(String userName, String password) throws JMSException
- Specified by:
createXATopicConnection
in interfaceXATopicConnectionFactory
- Throws:
JMSException
-
createActiveMQConnection
protected ActiveMQConnection createActiveMQConnection(Transport transport, JMSStatsImpl stats) throws Exception
- Overrides:
createActiveMQConnection
in classActiveMQConnectionFactory
- Throws:
Exception
-
getXaAckMode
public int getXaAckMode()
-
setXaAckMode
public void setXaAckMode(int xaAckMode)
-
populateProperties
public void populateProperties(Properties props)
Description copied from class:JNDIBaseStorable
Initialize the instance from properties stored in JNDI- Overrides:
populateProperties
in classActiveMQConnectionFactory
-
-