org.apache.activemq
Class ActiveMQXAConnectionFactory

java.lang.Object
  extended by org.apache.activemq.jndi.JNDIBaseStorable
      extended by org.apache.activemq.ActiveMQConnectionFactory
          extended by 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

Field Summary
 
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
 
Constructor Summary
ActiveMQXAConnectionFactory()
           
ActiveMQXAConnectionFactory(java.lang.String brokerURL)
           
ActiveMQXAConnectionFactory(java.lang.String userName, java.lang.String password, java.lang.String brokerURL)
           
ActiveMQXAConnectionFactory(java.lang.String userName, java.lang.String password, java.net.URI brokerURL)
           
ActiveMQXAConnectionFactory(java.net.URI brokerURL)
           
 
Method Summary
protected  ActiveMQConnection createActiveMQConnection(Transport transport, JMSStatsImpl stats)
           
 javax.jms.XAConnection createXAConnection()
           
 javax.jms.XAConnection createXAConnection(java.lang.String userName, java.lang.String password)
           
 javax.jms.XAQueueConnection createXAQueueConnection()
           
 javax.jms.XAQueueConnection createXAQueueConnection(java.lang.String userName, java.lang.String password)
           
 javax.jms.XATopicConnection createXATopicConnection()
           
 javax.jms.XATopicConnection createXATopicConnection(java.lang.String userName, java.lang.String password)
           
 
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, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isSendAcksAsync, isStatsEnabled, 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, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setSendAcksAsync, setSendTimeout, setStatsEnabled, setTransformer, setTransportListener, 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.QueueConnectionFactory
createQueueConnection, createQueueConnection
 
Methods inherited from interface javax.jms.TopicConnectionFactory
createTopicConnection, createTopicConnection
 
Methods inherited from interface javax.jms.ConnectionFactory
createConnection, createConnection
 

Constructor Detail

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)
Method Detail

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-2011 FuseSource, Corp.. All Rights Reserved.