org.activemq
Class ActiveMQXAConnectionFactory

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


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