@ComponentProfile(summary="Connection for supporting a native WebsphereMQ Client", tag="connections,websphere", recommended={NativeConsumer.class,NativeProducer.class}) public class AttachedConnection extends NativeConnection
This implementation creates a single MQQueueManager instance when the connection is started. This MQQueueManager instance is then shared across all components associated with this connection.
It is not recommended to use this type of connection, as a persistent MQQueueManager may stop some versions of WebsphereMQ from performing a controlled shutdown. In addition to this, it may also stop WebsphereMQ from recovering from an uncontrolled shutdown.
If you require SSL support then you should review this developerWorks article which contains a good primer about the settings that will be required for using SSL with the adapter.
Depending on your WebsphereMQ configuration you will need to have installed and configured the WebsphereMQ Client software for your platform. The jars from the WebsphereMQ Client software should be copied into the adapter's lib directory.
In the adapter configuration file this class is aliased as wmq-attached-connection which is the preferred alternative to the fully qualified classname when building your configuration.
License Required: BASIC
log
Constructor and Description |
---|
AttachedConnection() |
Modifier and Type | Method and Description |
---|---|
protected void |
initConnection() |
protected void |
startConnection() |
protected void |
stopConnection() |
closeConnection, getEnvironmentProperties, getQueueManager, getRedirectExceptionLogging, isEnabled, prepareConnection, setEnvironmentProperties, setQueueManager, setRedirectExceptionLogging
connectionAttempts, connectionRetryInterval, createLoggingStatement, getConnectionAttempts, getConnectionRetryInterval, logWarning, setConnectionAttempts, setConnectionRetryInterval
addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getLookupName, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setLookupName, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown
protected void startConnection() throws CoreException
startConnection
in class AdaptrisConnectionImp
CoreException
AdaptrisConnectionImp.startConnection()
protected void initConnection() throws CoreException
initConnection
in class NativeConnection
CoreException
AdaptrisConnectionImp.initConnection()
protected void stopConnection()
stopConnection
in class AdaptrisConnectionImp
AdaptrisConnectionImp.stopConnection()