Package com.adaptris.xa.jms.activemq

Class BasicActiveMqXAImplementation

java.lang.Object

com.adaptris.core.jms.VendorImplementationImp

com.adaptris.core.jms.UrlVendorImplementation

com.adaptris.xa.jms.activemq.BasicActiveMqXAImplementation

All Implemented Interfaces:

ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>, VendorImplementation, VendorImplementationBase, LicensedComponent, com.adaptris.xa.jms.XAVendorImplementation

Direct Known Subclasses:

AdvancedActiveMqXAImplementation

public class BasicActiveMqXAImplementation
extends UrlVendorImplementation
implements com.adaptris.xa.jms.XAVendorImplementation, LicensedComponent

ActiveMQ implementation of XAVendorImplementation.

This was built against ActiveMQ 5.2.0

In the adapter configuration file this class is aliased as basic-active-mq-xa-implementation which is the preferred alternative to the fully qualified classname when building your configuration.

Field Summary

Fields inherited from class com.adaptris.core.jms.VendorImplementationImp

log

Constructor Summary

Constructors

Constructor	Description
BasicActiveMqXAImplementation()
BasicActiveMqXAImplementation(java.lang.String url)

Method Summary

Modifier and Type	Method	Description
protected org.apache.activemq.ActiveMQXAConnectionFactory	create(java.lang.String url)
javax.jms.ConnectionFactory	createConnectionFactory()
javax.jms.XASession	createSession(javax.jms.Connection c, boolean transacted, int acknowledgeMode)
javax.jms.XAConnectionFactory	createXAConnectionFactory()	Returns a new instance of org.apache.activemq.ActiveMQXAConnectionFactory.
javax.jms.XASession	createXASession(javax.jms.XAConnection c)
boolean	isEnabled(License license)
void	prepare()

Methods inherited from class com.adaptris.core.jms.UrlVendorImplementation

connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl

Methods inherited from class com.adaptris.core.jms.VendorImplementationImp

applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createTopic, createTopicSubscriber

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.adaptris.core.jms.ConnectionComparator

connectionEquals

Methods inherited from interface com.adaptris.core.jms.VendorImplementation

createConnection

Methods inherited from interface com.adaptris.core.jms.VendorImplementationBase

createConsumer, createDestination, createQueue, createQueueReceiver, createTopic, createTopicSubscriber, retrieveBrokerDetailsForLogging

Constructor Detail

BasicActiveMqXAImplementation

public BasicActiveMqXAImplementation()

BasicActiveMqXAImplementation

public BasicActiveMqXAImplementation(java.lang.String url)

Method Detail

createConnectionFactory

public javax.jms.ConnectionFactory createConnectionFactory()
                                                    throws javax.jms.JMSException

Specified by:

createConnectionFactory in interface VendorImplementation

Throws:

javax.jms.JMSException

createXAConnectionFactory

public javax.jms.XAConnectionFactory createXAConnectionFactory()
                                                        throws javax.jms.JMSException

Returns a new instance of org.apache.activemq.ActiveMQXAConnectionFactory.

Specified by:

createXAConnectionFactory in interface com.adaptris.xa.jms.XAVendorImplementation

Returns:

an XAConnectionFactory

Throws:

javax.jms.JMSException - if any occur

createXASession

public javax.jms.XASession createXASession(javax.jms.XAConnection c)
                                    throws javax.jms.JMSException

Specified by:

createXASession in interface com.adaptris.xa.jms.XAVendorImplementation

Throws:

javax.jms.JMSException

createSession

public javax.jms.XASession createSession(javax.jms.Connection c,
                                         boolean transacted,
                                         int acknowledgeMode)
                                  throws javax.jms.JMSException

Specified by:

createSession in interface VendorImplementationBase

Overrides:

createSession in class VendorImplementationImp

Throws:

javax.jms.JMSException

create

protected org.apache.activemq.ActiveMQXAConnectionFactory create(java.lang.String url)

isEnabled

public boolean isEnabled(License license)

Specified by:

isEnabled in interface LicensedComponent

prepare

public void prepare()
             throws CoreException

Specified by:

prepare in interface ComponentLifecycleExtension

Overrides:

prepare in class VendorImplementationImp

Throws:

CoreException