Package com.adaptris.core.amqp.qpid.amqp_0_10

Class StandardQpidImplementation

java.lang.Object

com.adaptris.core.jms.VendorImplementationImp

com.adaptris.core.jms.UrlVendorImplementation

com.adaptris.core.amqp.qpid.amqp_0_10.StandardQpidImplementation

All Implemented Interfaces:

ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>, VendorImplementation, VendorImplementationBase

public class StandardQpidImplementation
extends UrlVendorImplementation

AMQP 0.10 / 0.9.1 / 0.9 / 0.8 implementation of VendorImplementation using Apache Qpid.

Everything required to configure the connection needs to be specified on the URL. If you configure a username and password on the wrapping JmsConnection in which case ConnectionFactory.createConnection(String, String) is used when creating the connection otherwise ConnectionFactory.createConnection() will be used.

This was built against org.apache.qpid:qpid-client:6.0.1

In the adapter configuration file this class is aliased as qpid-implementation-0-10 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
StandardQpidImplementation()

Method Summary

Modifier and Type	Method	Description
boolean	connectionEquals(VendorImplementationBase vendorImp)
javax.jms.ConnectionFactory	createConnectionFactory()

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

getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl

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

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

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.VendorImplementation

createConnection

Constructor Detail

StandardQpidImplementation

public StandardQpidImplementation()

Method Detail

createConnectionFactory

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

Throws:

javax.jms.JMSException

connectionEquals

public boolean connectionEquals(VendorImplementationBase vendorImp)

Specified by:

connectionEquals in interface ConnectionComparator<VendorImplementationBase>

Overrides:

connectionEquals in class UrlVendorImplementation