public class BasicSonicMqImplementation extends UrlVendorImplementation implements LicensedComponent
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
In the adapter configuration file this class is aliased as basic-sonic-mq-implementation which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: BASIC
log
Constructor and Description |
---|
BasicSonicMqImplementation() |
Modifier and Type | Method and Description |
---|---|
progress.message.jclient.ConnectionFactory |
createConnectionFactory()
Returns a new instance of
progress.message.jclient.ConnectionFactory . |
protected progress.message.jclient.ConnectionFactory |
createConnectionFactory(java.lang.String url) |
java.lang.String |
getConnectId() |
java.lang.String |
getConnectionUrls()
Return any additional urls in use.
|
boolean |
isEnabled(License license) |
void |
prepare() |
java.lang.String |
retrieveBrokerDetailsForLogging() |
void |
setConnectId(java.lang.String s)
Set the ConnectID for the connection factory.
|
void |
setConnectionUrls(java.lang.String s)
Set any additional urls to use when connecting to a broker.
|
connectionEquals, getBrokerUrl, setBrokerUrl
applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, createTopicSubscriber
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createConnection
public progress.message.jclient.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
Returns a new instance of progress.message.jclient.ConnectionFactory
.
createConnectionFactory
in interface VendorImplementation
QueueConnectionFactory
javax.jms.JMSException
- if any occurprotected progress.message.jclient.ConnectionFactory createConnectionFactory(java.lang.String url) throws javax.jms.JMSException
javax.jms.JMSException
public java.lang.String retrieveBrokerDetailsForLogging()
retrieveBrokerDetailsForLogging
in interface VendorImplementationBase
retrieveBrokerDetailsForLogging
in class UrlVendorImplementation
#retrieveBrokerDetailsForLogging()
public java.lang.String getConnectionUrls()
setConnectionUrls(String)
public void setConnectionUrls(java.lang.String s)
Sonic MQ provides the facility for high availability, this is where you would add in additional urls that should be used if the primary connection is unavailable
s
- the connectionUrls to set, comma delimitedpublic java.lang.String getConnectId()
public void setConnectId(java.lang.String s)
If the ConnectID is not set for a given connection factory, then one will be assigned dynamically. In the event of a connection being terminated unexpectedly, there can be a time delay within SonicMQ before a different ConnectID (associated with a given client-id) can be used to connect to a durable topic subscription or exclusive queue. Use of this parameter is optional, but is likely to be required if you are using multiple adapters in a fault-tolerant fashion.
s
- the connect id.ConnectionFactory.setConnectID(String)
public void prepare() throws CoreException
prepare
in interface ComponentLifecycleExtension
prepare
in class VendorImplementationImp
CoreException
public boolean isEnabled(License license)
isEnabled
in interface LicensedComponent