org.activemq
Class ActiveMQXAConnectionFactory

java.lang.Object
  org.activemq.jndi.JNDIBaseStorable
      org.activemq.ActiveMQConnectionFactory
          org.activemq.ActiveMQXAConnectionFactory

All Implemented Interfaces:

ConnectionFactory, QueueConnectionFactory, TopicConnectionFactory, XAConnectionFactory, XAQueueConnectionFactory, XATopicConnectionFactory, Referenceable, JNDIStorableInterface, StatsCapable, Service

public class ActiveMQXAConnectionFactory
extends ActiveMQConnectionFactory
implements XAConnectionFactory, XAQueueConnectionFactory, 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, String brokerURL)

ActiveMQXAConnectionFactory(String brokerURL)

ActiveMQXAConnectionFactory(String userName, String password, String brokerURL)

Method Summary

protected ActiveMQXAConnection	createActiveMQXAConnection(String userName, String password)
Connection	createConnection() Create a JMS Connection
Connection	createConnection(String userName, String password)
QueueConnection	createQueueConnection() Create a JMS QueueConnection
QueueConnection	createQueueConnection(String userName, String password)
TopicConnection	createTopicConnection() Create a JMS TopicConnection
TopicConnection	createTopicConnection(String userName, String password)
XAConnection	createXAConnection()
XAConnection	createXAConnection(String userName, String password)
XAQueueConnection	createXAQueueConnection()
XAQueueConnection	createXAQueueConnection(String userName, String password)
XATopicConnection	createXATopicConnection()
XATopicConnection	createXATopicConnection(String userName, 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(String brokerURL)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(String userName,
                                   String password,
                                   String brokerURL)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(BrokerContainer container)

ActiveMQXAConnectionFactory

public ActiveMQXAConnectionFactory(BrokerContainer container,
                                   String brokerURL)

Method Detail

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

createConnection

public Connection createConnection()
                            throws JMSException

Description copied from class: ActiveMQConnectionFactory

Create a JMS Connection

Specified by:

createConnection in interface ConnectionFactory

Overrides:

createConnection in class ActiveMQConnectionFactory

Returns:

the JMS Connection

Throws:

JMSException - if an error occurs creating the Connection

createConnection

public Connection createConnection(String userName,
                                   String password)
                            throws JMSException

Specified by:

createConnection in interface ConnectionFactory

Overrides:

createConnection in class ActiveMQConnectionFactory

Returns:

the Connection

Throws:

JMSException - if an error occurs creating the Connection

createQueueConnection

public QueueConnection createQueueConnection()
                                      throws JMSException

Description copied from class: ActiveMQConnectionFactory

Create a JMS QueueConnection

Specified by:

createQueueConnection in interface QueueConnectionFactory

Overrides:

createQueueConnection in class ActiveMQConnectionFactory

Returns:

the JMS QueueConnection

Throws:

JMSException - if an error occurs creating the Connection

createQueueConnection

public QueueConnection createQueueConnection(String userName,
                                             String password)
                                      throws JMSException

Specified by:

createQueueConnection in interface QueueConnectionFactory

Overrides:

createQueueConnection in class ActiveMQConnectionFactory

Returns:

the QueueConnection

Throws:

JMSException - if an error occurs creating the Connection

createTopicConnection

public TopicConnection createTopicConnection()
                                      throws JMSException

Description copied from class: ActiveMQConnectionFactory

Create a JMS TopicConnection

Specified by:

createTopicConnection in interface TopicConnectionFactory

Overrides:

createTopicConnection in class ActiveMQConnectionFactory

Returns:

the JMS TopicConnection

Throws:

JMSException - if an error occurs creating the Connection

createTopicConnection

public TopicConnection createTopicConnection(String userName,
                                             String password)
                                      throws JMSException

Specified by:

createTopicConnection in interface TopicConnectionFactory

Overrides:

createTopicConnection in class ActiveMQConnectionFactory

Returns:

the TopicConnection

Throws:

JMSException - if an error occurs creating the Connection

createActiveMQXAConnection

protected ActiveMQXAConnection createActiveMQXAConnection(String userName,
                                                          String password)
                                                   throws JMSException

Throws:

JMSException