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 of XAConnection
instances
- Version:
- $Revision: 564057 $
- 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, getConsumerFailoverRedeliveryWaitPeriod, getExceptionListener, getPassword, getPrefetchPolicy, getProducerWindowSize, getRedeliveryPolicy, getSendTimeout, getStats, getTransformer, getTransportListener, getUserName, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDispatchAsync, isExclusiveConsumer, isNestedMapAndListEnabled, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isSendAcksAsync, isStatsEnabled, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, populateProperties, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setBrokerURL, setClientID, setClientIdGenerator, setClientIDPrefix, setClientInternalExceptionListener, setCloseTimeout, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setNestedMapAndListEnabled, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setSendAcksAsync, setSendTimeout, setStatsEnabled, 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 |
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)
createXAConnection
public XAConnection createXAConnection()
throws JMSException
- Specified by:
createXAConnection
in interface XAConnectionFactory
- Throws:
JMSException
createXAConnection
public XAConnection createXAConnection(String userName,
String password)
throws JMSException
- Specified by:
createXAConnection
in interface XAConnectionFactory
- Throws:
JMSException
createXAQueueConnection
public XAQueueConnection createXAQueueConnection()
throws JMSException
- Specified by:
createXAQueueConnection
in interface XAQueueConnectionFactory
- Throws:
JMSException
createXAQueueConnection
public XAQueueConnection createXAQueueConnection(String userName,
String password)
throws JMSException
- Specified by:
createXAQueueConnection
in interface XAQueueConnectionFactory
- Throws:
JMSException
createXATopicConnection
public XATopicConnection createXATopicConnection()
throws JMSException
- Specified by:
createXATopicConnection
in interface XATopicConnectionFactory
- Throws:
JMSException
createXATopicConnection
public XATopicConnection createXATopicConnection(String userName,
String password)
throws JMSException
- Specified by:
createXATopicConnection
in interface XATopicConnectionFactory
- Throws:
JMSException
createActiveMQConnection
protected ActiveMQConnection createActiveMQConnection(Transport transport,
JMSStatsImpl stats)
throws Exception
- Overrides:
createActiveMQConnection
in class ActiveMQConnectionFactory
- Throws:
Exception
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.