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_PASSWORD, DEFAULT_PRODUCER_WINDOW_SIZE, DEFAULT_USER, dispatchAsync, password, userName, xaAckMode
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) |
int |
getXaAckMode() |
void |
populateProperties(Properties props)
Initialize the instance from properties stored in JNDI
|
void |
setXaAckMode(int xaAckMode) |
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
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
public int getXaAckMode()
public void setXaAckMode(int xaAckMode)
public void populateProperties(Properties props)
JNDIBaseStorable
populateProperties
in class ActiveMQConnectionFactory
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.