@ComponentProfile(summary="JMS Queue only support for OracleAQ", since="3.9.2") public class OracleAqQueueImplementation extends OracleAqImplementation
OracleAqImplementation
.
This implementation is suitable if your OracleAQ JMS Driver isn't JMS 1.1 compliant, and limits you to using queues only. You really should think about upgrading to a JMS1.1 compliant driver.
In the adapter configuration file this class is aliased as oracleaq-queue-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
log
Constructor and Description |
---|
OracleAqQueueImplementation() |
Modifier and Type | Method and Description |
---|---|
javax.jms.Connection |
createConnection(javax.jms.ConnectionFactory factory,
JmsConnectionConfig cfg) |
javax.jms.ConnectionFactory |
createConnectionFactory() |
javax.jms.Topic |
createTopic(java.lang.String name,
JmsActorConfig c) |
javax.jms.MessageConsumer |
createTopicSubscriber(ConsumeDestination cd,
java.lang.String subscriptionId,
JmsActorConfig c) |
applyVendorSessionProperties, createQueue, createQueueReceiver, getAdditionalProperties, getSessionProperties, isEnabled, prepare, setAdditionalProperties, setSessionProperties
connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl
createConsumer, createDestination, createSession
public javax.jms.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
createConnectionFactory
in interface VendorImplementation
createConnectionFactory
in class OracleAqImplementation
javax.jms.JMSException
public javax.jms.Topic createTopic(java.lang.String name, JmsActorConfig c) throws javax.jms.JMSException
createTopic
in interface VendorImplementationBase
createTopic
in class OracleAqImplementation
javax.jms.JMSException
public javax.jms.MessageConsumer createTopicSubscriber(ConsumeDestination cd, java.lang.String subscriptionId, JmsActorConfig c) throws javax.jms.JMSException
createTopicSubscriber
in interface VendorImplementationBase
createTopicSubscriber
in class OracleAqImplementation
javax.jms.JMSException
public javax.jms.Connection createConnection(javax.jms.ConnectionFactory factory, JmsConnectionConfig cfg) throws java.lang.Exception
java.lang.Exception