Class BasicQpidImplementation
- java.lang.Object
-
- com.adaptris.core.jms.VendorImplementationImp
-
- com.adaptris.core.jms.UrlVendorImplementation
-
- com.adaptris.core.amqp.qpid.BasicQpidImplementation
-
- All Implemented Interfaces:
ComponentLifecycleExtension
,ConnectionComparator<VendorImplementationBase>
,VendorImplementation
,VendorImplementationBase
public class BasicQpidImplementation extends UrlVendorImplementation
AMQP 1.0 implementation ofVendorImplementation
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 caseConnectionFactory.createConnection(String, String)
is used when creating the connection otherwiseConnectionFactory.createConnection()
will be used.This vendor implementation is suitable for use with Azure AMQP. If you are using a topic consumer then it must be a durable subscriber where the subscriptionID is the same as the subscription created in the Azure portal; the topic name should be
[topic-name]/subscriptions/[subscriptionID]
. Your mileage may vary but during testing this was the the only destination configuration that seemed to work; the documentation suggests that this might actually pretending to be aqueue
.This was built against
org.apache.qpid:qpid-amqp-1-0-client-jms:0.32
.In the adapter configuration file this class is aliased as qpid-basic-amqp-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 BasicQpidImplementation()
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceConnectionComparator<VendorImplementationBase>
- Overrides:
connectionEquals
in classUrlVendorImplementation
-
-