org.activemq
Class ActiveMQXAConnectionFactory
java.lang.Object
org.activemq.jndi.JNDIBaseStorable
org.activemq.ActiveMQConnectionFactory
org.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
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 |
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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)
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.