public class ActiveMQXAConnectionFactory extends ActiveMQConnectionFactory implements javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory
XAConnection
instancesalwaysSessionAsync, brokerURL, clientID, DEFAULT_BROKER_BIND_URL, DEFAULT_BROKER_URL, DEFAULT_CONNECTION_EXECUTOR, DEFAULT_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName
Constructor and Description |
---|
ActiveMQXAConnectionFactory() |
ActiveMQXAConnectionFactory(String brokerURL) |
ActiveMQXAConnectionFactory(String userName,
String password,
String brokerURL) |
ActiveMQXAConnectionFactory(String userName,
String password,
URI brokerURL) |
ActiveMQXAConnectionFactory(URI brokerURL) |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQConnection |
createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
javax.jms.XAConnection |
createXAConnection() |
javax.jms.XAConnection |
createXAConnection(String userName,
String password) |
javax.jms.XAQueueConnection |
createXAQueueConnection() |
javax.jms.XAQueueConnection |
createXAQueueConnection(String userName,
String password) |
javax.jms.XATopicConnection |
createXATopicConnection() |
javax.jms.XATopicConnection |
createXATopicConnection(String userName,
String password) |
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
getProperties, getReference, readExternal, setProperties, writeExternal
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createQueueConnection, createQueueConnection
public ActiveMQXAConnectionFactory()
public ActiveMQXAConnectionFactory(String userName, String password, String brokerURL)
public ActiveMQXAConnectionFactory(String userName, String password, URI brokerURL)
public ActiveMQXAConnectionFactory(String brokerURL)
public ActiveMQXAConnectionFactory(URI brokerURL)
public javax.jms.XAConnection createXAConnection() throws javax.jms.JMSException
createXAConnection
in interface javax.jms.XAConnectionFactory
javax.jms.JMSException
public javax.jms.XAConnection createXAConnection(String userName, String password) throws javax.jms.JMSException
createXAConnection
in interface javax.jms.XAConnectionFactory
javax.jms.JMSException
public javax.jms.XAQueueConnection createXAQueueConnection() throws javax.jms.JMSException
createXAQueueConnection
in interface javax.jms.XAQueueConnectionFactory
javax.jms.JMSException
public javax.jms.XAQueueConnection createXAQueueConnection(String userName, String password) throws javax.jms.JMSException
createXAQueueConnection
in interface javax.jms.XAQueueConnectionFactory
javax.jms.JMSException
public javax.jms.XATopicConnection createXATopicConnection() throws javax.jms.JMSException
createXATopicConnection
in interface javax.jms.XATopicConnectionFactory
javax.jms.JMSException
public javax.jms.XATopicConnection createXATopicConnection(String userName, String password) throws javax.jms.JMSException
createXATopicConnection
in interface javax.jms.XATopicConnectionFactory
javax.jms.JMSException
protected ActiveMQConnection createActiveMQConnection(Transport transport, JMSStatsImpl stats) throws Exception
createActiveMQConnection
in class ActiveMQConnectionFactory
Exception
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.