org.apache.activemq
Class ActiveMQXAConnectionFactory
java.lang.Object
org.apache.activemq.jndi.JNDIBaseStorable
org.apache.activemq.ActiveMQConnectionFactory
org.apache.activemq.ActiveMQXAConnectionFactory
- All Implemented Interfaces:
- java.io.Externalizable, java.io.Serializable, java.lang.Cloneable, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory, javax.naming.Referenceable, JNDIStorableInterface, StatsCapable
- Direct Known Subclasses:
- ActiveMQXAConnectionFactory
public class ActiveMQXAConnectionFactory
- extends ActiveMQConnectionFactory
- implements javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory
A factory of XAConnection
instances
- See Also:
- Serialized Form
Fields inherited from class org.apache.activemq.ActiveMQConnectionFactory |
alwaysSessionAsync, brokerURL, clientID, DEFAULT_BROKER_BIND_URL, DEFAULT_BROKER_URL, DEFAULT_CONNECTION_EXECUTOR, DEFAULT_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName |
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, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getOptimizeAcknowledgeTimeOut, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getSendTimeout, getStats, getTransformer, getTransportListener, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isSendAcksAsync, isStatsEnabled, isTransactedIndividualAck, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, populateProperties, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setCheckForDuplicates, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConnectionIdGenerator, setConnectionIDPrefix, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setSendAcksAsync, setSendTimeout, setStatsEnabled, setTransactedIndividualAck, setTransformer, setTransportListener, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.QueueConnectionFactory |
createQueueConnection, createQueueConnection |
Methods inherited from interface javax.jms.TopicConnectionFactory |
createTopicConnection, createTopicConnection |
Methods inherited from interface javax.jms.ConnectionFactory |
createConnection, createConnection |
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory()
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(java.lang.String userName,
java.lang.String password,
java.lang.String brokerURL)
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(java.lang.String userName,
java.lang.String password,
java.net.URI brokerURL)
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(java.lang.String brokerURL)
ActiveMQXAConnectionFactory
public ActiveMQXAConnectionFactory(java.net.URI brokerURL)
createXAConnection
public javax.jms.XAConnection createXAConnection()
throws javax.jms.JMSException
- Specified by:
createXAConnection
in interface javax.jms.XAConnectionFactory
- Throws:
javax.jms.JMSException
createXAConnection
public javax.jms.XAConnection createXAConnection(java.lang.String userName,
java.lang.String password)
throws javax.jms.JMSException
- Specified by:
createXAConnection
in interface javax.jms.XAConnectionFactory
- Throws:
javax.jms.JMSException
createXAQueueConnection
public javax.jms.XAQueueConnection createXAQueueConnection()
throws javax.jms.JMSException
- Specified by:
createXAQueueConnection
in interface javax.jms.XAQueueConnectionFactory
- Throws:
javax.jms.JMSException
createXAQueueConnection
public javax.jms.XAQueueConnection createXAQueueConnection(java.lang.String userName,
java.lang.String password)
throws javax.jms.JMSException
- Specified by:
createXAQueueConnection
in interface javax.jms.XAQueueConnectionFactory
- Throws:
javax.jms.JMSException
createXATopicConnection
public javax.jms.XATopicConnection createXATopicConnection()
throws javax.jms.JMSException
- Specified by:
createXATopicConnection
in interface javax.jms.XATopicConnectionFactory
- Throws:
javax.jms.JMSException
createXATopicConnection
public javax.jms.XATopicConnection createXATopicConnection(java.lang.String userName,
java.lang.String password)
throws javax.jms.JMSException
- Specified by:
createXATopicConnection
in interface javax.jms.XATopicConnectionFactory
- Throws:
javax.jms.JMSException
createActiveMQConnection
protected ActiveMQConnection createActiveMQConnection(Transport transport,
JMSStatsImpl stats)
throws java.lang.Exception
- Overrides:
createActiveMQConnection
in class ActiveMQConnectionFactory
- Throws:
java.lang.Exception
Copyright © 2005-2015. All Rights Reserved.