com.adaptris.core.jms.oracle

Class OracleAqTopicImplementation

java.lang.Object

com.adaptris.core.jms.VendorImplementationImp

com.adaptris.core.jms.UrlVendorImplementation

com.adaptris.core.jms.oracle.OracleAqImplementation

com.adaptris.core.jms.oracle.OracleAqTopicImplementation

All Implemented Interfaces:

ComponentLifecycleExtension, ConnectionComparator<VendorImplementationBase>, VendorImplementation, VendorImplementationBase, LicensedComponent

@ComponentProfile(summary="JMS Topic only support for OracleAQ",
                  since="3.9.2")
public class OracleAqTopicImplementation
extends OracleAqImplementation

Topic specific variation of OracleAqImplementation.

This implementation is suitable if your OracleAQ JMS Driver isn't JMS 1.1 compliant, and limits you to using topics only. You really should think about upgrading to a JMS1.1 compliant driver.

In the adapter configuration file this class is aliased as oracleaq-topic-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 and Description
OracleAqTopicImplementation()

Method Summary

Modifier and Type	Method and Description
javax.jms.Connection	createConnection(javax.jms.ConnectionFactory factory, JmsConnectionConfig cfg)
javax.jms.ConnectionFactory	createConnectionFactory()
javax.jms.Queue	createQueue(java.lang.String qName, JmsActorConfig c)
javax.jms.MessageConsumer	createQueueReceiver(ConsumeDestination cd, JmsActorConfig c)

Methods inherited from class com.adaptris.core.jms.oracle.OracleAqImplementation

applyVendorSessionProperties, createTopic, createTopicSubscriber, getAdditionalProperties, getSessionProperties, isEnabled, prepare, setAdditionalProperties, setSessionProperties

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

connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl

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

createConsumer, createDestination, createSession

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OracleAqTopicImplementation

public OracleAqTopicImplementation()

Method Detail

createConnectionFactory

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

Specified by:

createConnectionFactory in interface VendorImplementation

Overrides:

createConnectionFactory in class OracleAqImplementation

Throws:

javax.jms.JMSException

createQueueReceiver

public javax.jms.MessageConsumer createQueueReceiver(ConsumeDestination cd,
                                                     JmsActorConfig c)
                                              throws javax.jms.JMSException

Specified by:

createQueueReceiver in interface VendorImplementationBase

Overrides:

createQueueReceiver in class OracleAqImplementation

Throws:

javax.jms.JMSException

createQueue

public javax.jms.Queue createQueue(java.lang.String qName,
                                   JmsActorConfig c)
                            throws javax.jms.JMSException

Specified by:

createQueue in interface VendorImplementationBase

Overrides:

createQueue in class OracleAqImplementation

Throws:

javax.jms.JMSException

createConnection

public javax.jms.Connection createConnection(javax.jms.ConnectionFactory factory,
                                             JmsConnectionConfig cfg)
                                      throws java.lang.Exception

Throws:

java.lang.Exception