Class BasicQpidImplementation
- All Implemented Interfaces:
ComponentLifecycleExtension
,ConnectionComparator<VendorImplementationBase>
,VendorImplementation
,VendorImplementationBase
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 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 a queue
.
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 -
Method Summary
Modifier and TypeMethodDescriptionboolean
connectionEquals
(VendorImplementationBase vendorImp) javax.jms.ConnectionFactory
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 Details
-
BasicQpidImplementation
public BasicQpidImplementation()
-
-
Method Details
-
createConnectionFactory
public javax.jms.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException- Throws:
javax.jms.JMSException
-
connectionEquals
- Specified by:
connectionEquals
in interfaceConnectionComparator<VendorImplementationBase>
- Overrides:
connectionEquals
in classUrlVendorImplementation
-