public class AdvancedSonicMqImplementation extends BasicSonicMqImplementation
Progress SonicMQ implementation of VendorImplementation
.
Depending on your SonicMQ configuration you will need at least the sonic_Client.jar sonic_Channel.jar sonic_Crypto.jar sonic_XMessage.jar from your SonicMQ installation
This vendor implementation class directly exposes almost all the getter and setters that are available in the ConnectionFactory for maximum flexibility in configuration.
The key from the connection-factory-properties
element should match the name of the underlying Progress
ConnectionFactory property.
will invoke
<connection-factory-properties>
<key-value-pair>
<key>PrefetchCount</key>
<value>10</value>
</key-value-pair>
</connection-factory-properties>
ConnectionFactory.setPrefetchCount(int)
with 10, setting the PreFetchCount
property to 10.
This vendor implementation also overrides VendorImplementationImp.applyVendorSessionProperties(javax.jms.Session)
so that
specific SonicMQ 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>AckBatchingEnabled</key>
<value>true</value>
</key-value-pair>
</session-properties>
Session.setAckBatchingEnabled(boolean)
with true.
This was built against SonicMQ 8.5
ConnectionFactory
In the adapter configuration file this class is aliased as advanced-sonic-mq-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: BASIC
Modifier and Type | Class and Description |
---|---|
static class |
AdvancedSonicMqImplementation.ConnectionFactoryProperty
Properties matched against various MQConnectionFactory methods.
|
static class |
AdvancedSonicMqImplementation.SessionProperty
Properties matched against various SonicMQ Session methods.
|
log
Constructor and Description |
---|
AdvancedSonicMqImplementation() |
Modifier and Type | Method and Description |
---|---|
void |
applyVendorSessionProperties(javax.jms.Session s) |
protected progress.message.jclient.ConnectionFactory |
createConnectionFactory(java.lang.String url) |
KeyValuePairSet |
getConnectionFactoryProperties() |
KeyValuePairSet |
getSessionProperties() |
void |
setConnectionFactoryProperties(KeyValuePairSet crp) |
void |
setSessionProperties(KeyValuePairSet s)
Set any additional session properties to be applied.
|
createConnectionFactory, getConnectId, getConnectionUrls, isEnabled, prepare, retrieveBrokerDetailsForLogging, setConnectId, setConnectionUrls
connectionEquals, getBrokerUrl, setBrokerUrl
createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, createTopicSubscriber
protected progress.message.jclient.ConnectionFactory createConnectionFactory(java.lang.String url) throws javax.jms.JMSException
createConnectionFactory
in class BasicSonicMqImplementation
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 getConnectionFactoryProperties()
public void setConnectionFactoryProperties(KeyValuePairSet crp)
crp
- the additional connectionFactoryProperties to setAdvancedSonicMqImplementation.ConnectionFactoryProperty
public KeyValuePairSet getSessionProperties()
public void setSessionProperties(KeyValuePairSet s)
s
- the sessionProperties to setAdvancedSonicMqImplementation.SessionProperty
Copyright Adaptris