Class BasicSonicMqImplementation
- java.lang.Object
-
- com.adaptris.core.jms.VendorImplementationImp
-
- com.adaptris.core.jms.UrlVendorImplementation
-
- com.adaptris.core.jms.sonic.BasicSonicMqImplementation
-
- All Implemented Interfaces:
ComponentLifecycleExtension
,ConnectionComparator<VendorImplementationBase>
,VendorImplementation
,VendorImplementationBase
,LicensedComponent
- Direct Known Subclasses:
AdvancedSonicMqImplementation
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
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.jms.VendorImplementationImp
log
-
-
Constructor Summary
Constructors Constructor Description BasicSonicMqImplementation()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description progress.message.jclient.ConnectionFactory
createConnectionFactory()
Returns a new instance ofprogress.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.-
Methods inherited from class com.adaptris.core.jms.UrlVendorImplementation
connectionEquals, getBrokerUrl, setBrokerUrl
-
Methods inherited from class com.adaptris.core.jms.VendorImplementationImp
applyVendorSessionProperties, createConsumer, createDestination, createQueue, createQueueReceiver, createSession, createTopic, createTopicSubscriber
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.jms.VendorImplementation
createConnection
-
-
-
-
Method Detail
-
createConnectionFactory
public progress.message.jclient.ConnectionFactory createConnectionFactory() throws javax.jms.JMSException
Returns a new instance of
progress.message.jclient.ConnectionFactory
.- Specified by:
createConnectionFactory
in interfaceVendorImplementation
- Returns:
- a
QueueConnectionFactory
- Throws:
javax.jms.JMSException
- if any occur
-
createConnectionFactory
protected progress.message.jclient.ConnectionFactory createConnectionFactory(java.lang.String url) throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
-
retrieveBrokerDetailsForLogging
public java.lang.String retrieveBrokerDetailsForLogging()
- Specified by:
retrieveBrokerDetailsForLogging
in interfaceVendorImplementationBase
- Overrides:
retrieveBrokerDetailsForLogging
in classUrlVendorImplementation
- See Also:
#retrieveBrokerDetailsForLogging()
-
getConnectionUrls
public java.lang.String getConnectionUrls()
Return any additional urls in use.- Returns:
- Returns the connectionUrls.
- See Also:
setConnectionUrls(String)
-
setConnectionUrls
public void setConnectionUrls(java.lang.String s)
Set any additional urls to use when connecting to a broker.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
- Parameters:
s
- the connectionUrls to set, comma delimited
-
getConnectId
public java.lang.String getConnectId()
-
setConnectId
public void setConnectId(java.lang.String s)
Set the ConnectID for the connection factory.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.
- Parameters:
s
- the connect id.- See Also:
ConnectionFactory.setConnectID(String)
-
prepare
public void prepare() throws CoreException
- Specified by:
prepare
in interfaceComponentLifecycleExtension
- Overrides:
prepare
in classVendorImplementationImp
- Throws:
CoreException
-
isEnabled
public boolean isEnabled(License license)
- Specified by:
isEnabled
in interfaceLicensedComponent
-
-