public class OracleAqImplementation extends UrlVendorImplementation implements LicensedComponent
When using this implementation you should explicitly configure the broker-url in the appropriate JmsConnection. This should be
the correct url for making a connection to the Oracle database in question e.g.
jdbc:oracle:thin:@localhost:1521:<OracleSid>
The oracle jar files are not shipped with the standard adapter installer, so you will need to provide your own jar files from your oracle installation. Depending on your configuration, you will need at least the aqapi and jdbc (JDK1.4) jar.
When configuring the destination queue name you may use . to separate out the owner (sometimes referred
to as schema) from the actual Queue name. In this instance the corresponding AQjmsSession.getTopic(String, String)
and
AQjmsSession.getQueue(String, String)
methods will be used.
This vendor implementation also overrides VendorImplementationImp#applyVendorSessionProperties(javax.jms.Session)
so that
specific Oracle session properties can be applied. The way of doing this is exactly the same as setting properties on the
ConnectionFactory.
would invoke
<session-properties>
<key-value-pair>
<key>CloseCheckInterval</key>
<value>15</value>
</key-value-pair>
</session-properties>
AQjmsSession.setCloseCheckInterval(int)
with 15.
In the adapter configuration file this class is aliased as oracleaq-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: BASIC
log
Constructor and Description |
---|
OracleAqImplementation() |
Modifier and Type | Method and Description |
---|---|
void |
applyVendorSessionProperties(javax.jms.Session s) |
javax.jms.ConnectionFactory |
createConnectionFactory() |
javax.jms.Queue |
createQueue(java.lang.String qName,
JmsActorConfig c) |
javax.jms.MessageConsumer |
createQueueReceiver(ConsumeDestination cd,
JmsActorConfig c) |
javax.jms.Topic |
createTopic(java.lang.String name,
JmsActorConfig c) |
javax.jms.MessageConsumer |
createTopicSubscriber(ConsumeDestination cd,
java.lang.String subscriptionId,
JmsActorConfig c) |
KeyValuePairSet |
getAdditionalProperties()
Return any additional properties passed through to the AQjmsFactory.
|
KeyValuePairSet |
getSessionProperties() |
boolean |
isEnabled(License license) |
void |
prepare() |
void |
setAdditionalProperties(KeyValuePairSet kvps)
Set additional properties that should be passed through to the
AQjmsFactory.
|
void |
setSessionProperties(KeyValuePairSet sp)
Any additional properties to apply on the session.
|
connectionEquals, getBrokerUrl, retrieveBrokerDetailsForLogging, setBrokerUrl
createConsumer, createDestination, createSession
public javax.jms.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
createConnectionFactory
in interface VendorImplementation
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 VendorImplementationImp
javax.jms.JMSException
public javax.jms.Queue createQueue(java.lang.String qName, JmsActorConfig c) throws javax.jms.JMSException
createQueue
in interface VendorImplementationBase
createQueue
in class VendorImplementationImp
javax.jms.JMSException
public void applyVendorSessionProperties(javax.jms.Session s) throws javax.jms.JMSException
applyVendorSessionProperties
in class VendorImplementationImp
javax.jms.JMSException
VendorImplementationImp#applyVendorSessionProperties(javax.jms.Session)
public KeyValuePairSet getAdditionalProperties()
public void setAdditionalProperties(KeyValuePairSet kvps)
kvps
- the additionalProperties to setpublic javax.jms.MessageConsumer createQueueReceiver(ConsumeDestination cd, JmsActorConfig c) throws javax.jms.JMSException
createQueueReceiver
in interface VendorImplementationBase
createQueueReceiver
in class VendorImplementationImp
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 VendorImplementationImp
javax.jms.JMSException
public KeyValuePairSet getSessionProperties()
public void setSessionProperties(KeyValuePairSet sp)
sp
- the sessionProperties to setVendorImplementationImp#applyVendorSessionProperties(javax.jms.Session)
public void prepare() throws CoreException
prepare
in interface ComponentLifecycleExtension
prepare
in class VendorImplementationImp
CoreException
public boolean isEnabled(License license)
isEnabled
in interface LicensedComponent