org.activemq
Class ActiveMQXAConnectionFactory

java.lang.Object
  extended byorg.activemq.jndi.JNDIBaseStorable
      extended byorg.activemq.ActiveMQConnectionFactory
          extended byorg.activemq.ActiveMQXAConnectionFactory
All Implemented Interfaces:
javax.jms.ConnectionFactory, JNDIStorableInterface, javax.jms.QueueConnectionFactory, javax.naming.Referenceable, Service, StatsCapable, javax.jms.TopicConnectionFactory, javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory

public class ActiveMQXAConnectionFactory
extends ActiveMQConnectionFactory
implements javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory

The XAConnectionFactory interface is a base interface for the XAQueueConnectionFactory and XATopicConnectionFactory interfaces.

Some application servers provide support for grouping JTS capable resource use into a distributed transaction (optional). To include JMS API transactions in a JTS transaction, an application server requires a JTS aware JMS provider. A JMS provider exposes its JTS support using an XAConnectionFactory object, which an application server uses to create XAConnection objects.

XAConnectionFactory objects are JMS administered objects, just like ConnectionFactory objects. It is expected that application servers will find them using the Java Naming and Directory Interface (JNDI) API.

The XAConnectionFactory interface is optional. JMS providers are not required to support this interface. This interface is for use by JMS providers to support transactional environments. Client programs are strongly encouraged to use the transactional support available in their environment, rather than use these XA interfaces directly.

Version:
$Revision: 1.1.1.1 $
See Also:
ConnectionFactory

Field Summary
 
Fields inherited from class org.activemq.ActiveMQConnectionFactory
brokerContainer, brokerName, brokerURL, cachingEnabled, clientID, copyMessageOnSend, disableTimeStampsByDefault, doMessageCompression, doMessageFragmentation, internalConnection, J2EEcompliant, messageCompressionLevel, messageCompressionLimit, messageCompressionStrategy, messageFragmentationLimit, optimizedMessageDispatch, password, prepareMessageBodyOnSend, quickClose, useAsyncSend, userName
 
Constructor Summary
ActiveMQXAConnectionFactory()
           
ActiveMQXAConnectionFactory(BrokerContainer container)
           
ActiveMQXAConnectionFactory(BrokerContainer container, java.lang.String brokerURL)
           
ActiveMQXAConnectionFactory(java.lang.String brokerURL)
           
ActiveMQXAConnectionFactory(java.lang.String userName, java.lang.String password, java.lang.String brokerURL)
           
 
Method Summary
protected  ActiveMQXAConnection createActiveMQXAConnection(java.lang.String userName, java.lang.String password)
           
 javax.jms.Connection createConnection()
          Create a JMS Connection
 javax.jms.Connection createConnection(java.lang.String userName, java.lang.String password)
           
 javax.jms.QueueConnection createQueueConnection()
          Create a JMS QueueConnection
 javax.jms.QueueConnection createQueueConnection(java.lang.String userName, java.lang.String password)
           
 javax.jms.TopicConnection createTopicConnection()
          Create a JMS TopicConnection
 javax.jms.TopicConnection createTopicConnection(java.lang.String userName, java.lang.String password)
           
 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.activemq.ActiveMQConnectionFactory
buildFromProperties, createBrokerConnector, createBrokerContainerFactory, createMulticastClientID, createTransportChannel, createURI, createURI, ensureMulticastChannelIsAvailable, ensureServerIsAvailable, getBoolean, getBoolean, getBrokerContainer, getBrokerContainerFactory, getBrokerContext, getBrokerName, getBrokerName, getBrokerURL, getBrokerXmlConfig, getClientID, getContainer, getEmbeddedBroker, getFactoryStats, getMessageCompressionLimit, getMessageCompressionStrategy, getMessageFragmentationLimit, getPassword, getPrefetchPolicy, getStats, getUserName, getWireFormat, isCachingEnabled, isCopyMessageOnSend, isDisableTimeStampsByDefault, isDoMessageCompression, isDoMessageFragmentation, isInternalConnection, isJ2EEcompliant, isOptimizedMessageDispatch, isPrepareMessageBodyOnSend, isQuickClose, isTurboBoost, isUseAsyncSend, isUseEmbeddedBroker, populateProperties, registerBroker, setBrokerContainerFactory, setBrokerContext, setBrokerName, setBrokerURL, setBrokerXmlConfig, setCachingEnabled, setClientID, setCopyMessageOnSend, setDisableTimeStampsByDefault, setDoMessageCompression, setDoMessageFragmentation, setInternalConnection, setJ2EEcompliant, setMessageCompressionLimit, setMessageCompressionStrategy, setMessageFragmentationLimit, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setPrepareMessageBodyOnSend, setQuickClose, setTurboBoost, setUseAsyncSend, setUseEmbeddedBroker, setUserName, setWireFormat, setWireFormat, start, stop, unregisterBroker
 
Methods inherited from class org.activemq.jndi.JNDIBaseStorable
getProperties, getReference, setProperties
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory()

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(java.lang.String brokerURL)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(java.lang.String userName,
                                   java.lang.String password,
                                   java.lang.String brokerURL)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(BrokerContainer container)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(BrokerContainer container,
                                   java.lang.String 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

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException
Description copied from class: ActiveMQConnectionFactory
Create a JMS Connection

Specified by:
createConnection in interface javax.jms.ConnectionFactory
Overrides:
createConnection in class ActiveMQConnectionFactory
Returns:
the JMS Connection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createConnection

public javax.jms.Connection createConnection(java.lang.String userName,
                                             java.lang.String password)
                                      throws javax.jms.JMSException
Specified by:
createConnection in interface javax.jms.ConnectionFactory
Overrides:
createConnection in class ActiveMQConnectionFactory
Parameters:
userName -
password -
Returns:
the Connection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException
Description copied from class: ActiveMQConnectionFactory
Create a JMS QueueConnection

Specified by:
createQueueConnection in interface javax.jms.QueueConnectionFactory
Overrides:
createQueueConnection in class ActiveMQConnectionFactory
Returns:
the JMS QueueConnection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createQueueConnection

public javax.jms.QueueConnection createQueueConnection(java.lang.String userName,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException
Specified by:
createQueueConnection in interface javax.jms.QueueConnectionFactory
Overrides:
createQueueConnection in class ActiveMQConnectionFactory
Parameters:
userName -
password -
Returns:
the QueueConnection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createTopicConnection

public javax.jms.TopicConnection createTopicConnection()
                                                throws javax.jms.JMSException
Description copied from class: ActiveMQConnectionFactory
Create a JMS TopicConnection

Specified by:
createTopicConnection in interface javax.jms.TopicConnectionFactory
Overrides:
createTopicConnection in class ActiveMQConnectionFactory
Returns:
the JMS TopicConnection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createTopicConnection

public javax.jms.TopicConnection createTopicConnection(java.lang.String userName,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException
Specified by:
createTopicConnection in interface javax.jms.TopicConnectionFactory
Overrides:
createTopicConnection in class ActiveMQConnectionFactory
Parameters:
userName -
password -
Returns:
the TopicConnection
Throws:
javax.jms.JMSException - if an error occurs creating the Connection

createActiveMQXAConnection

protected ActiveMQXAConnection createActiveMQXAConnection(java.lang.String userName,
                                                          java.lang.String password)
                                                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.