public class BasicActiveMqImplementation extends UrlVendorImplementation implements VendorImplementation
ActiveMQ implementation of VendorImplementation
.
This was built against ActiveMQ 5.2.0
In the adapter configuration file this class is aliased as basic-active-mq-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
log
Constructor and Description |
---|
BasicActiveMqImplementation() |
BasicActiveMqImplementation(java.lang.String url) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.activemq.ActiveMQConnectionFactory |
create(java.lang.String url) |
javax.jms.ConnectionFactory |
createConnectionFactory()
Returns a new instance of
org.apache.activemq.ActiveMQConnectionFactory . |
connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl
applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, createTopicSubscriber, prepare
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createConnection
createConsumer, createDestination, createQueue, createQueueReceiver, createQueueReceiver, createSession, createTopic, createTopicSubscriber, createTopicSubscriber, retrieveBrokerDetailsForLogging
prepare
connectionEquals
public BasicActiveMqImplementation()
public BasicActiveMqImplementation(java.lang.String url)
public javax.jms.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
Returns a new instance of
org.apache.activemq.ActiveMQConnectionFactory
.
createConnectionFactory
in interface VendorImplementation
QueueConnectionFactory
javax.jms.JMSException
- if any occurprotected org.apache.activemq.ActiveMQConnectionFactory create(java.lang.String url)