com.ibm.di.systemqueue.driver
Class IBMMQ

java.lang.Object
  com.ibm.di.systemqueue.driver.IBMMQ

All Implemented Interfaces:

JMSDriver

Direct Known Subclasses:

IBMMQ

public class IBMMQ
extends Object
implements JMSDriver

The Websphere MQ Series JMS Driver implementation. It initialize the JMS Driver and provides specific way for obtaining JMS QueueConnectionFactory.

Field Summary

protected JMSDriverLog	log
protected String	mChannel Driver properties for Channel
protected String	mCipherSuite Driver properties for CipherSuit
protected String	mHost Driver properties for Host
protected int	mPort Driver properties for Port
protected String	mQmgr Driver properties for QueueManager
protected boolean	mSSL Driver properties for SSL
protected String	mURL Driver properties for Url
static String	PROP_MQ_BROKER JMS Driver property name used for broker
static String	PROP_MQ_CHANNEL JMS Driver property name used for channel
static String	PROP_MQ_QMANAGER JMS Driver property name used for queue manager
static String	PROP_MQ_SSL_CIPHER JMS Driver property name used for sslCipher
static String	PROP_MQ_SSL_USE_FLAG JMS Driver property name used for ssl flag
protected ResourceHash	resHash ResourceHash used for access of the TMS messages

Fields inherited from interface com.ibm.di.systemqueue.driver.JMSDriver

ENVIRONMENT_LOG, JMS_DRIVER_TMS_FILE

Constructor Summary

IBMMQ()

Method Summary

javax.jms.QueueConnectionFactory	getQueueFactory() This method retrieves the provider-specific javax.jms.QueueConnectionFactory object
javax.jms.TopicConnectionFactory	getTopicFactory() This method retrieves the provider-specific javax.jms.TopicConnectionFactory object
void	initialize(Hashtable env) The initialize(Hastable env) method is passed a java.util.Hashtable object which stores provider-specific parameters, which can be used for connecting to a specific instance of the JMS server.
void	terminate() This is a call-back method used to notify the JMS Driver so it could clean any used resources.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROP_MQ_BROKER

public static final String PROP_MQ_BROKER

JMS Driver property name used for broker

See Also:

Constant Field Values

PROP_MQ_CHANNEL

public static final String PROP_MQ_CHANNEL

JMS Driver property name used for channel

See Also:

Constant Field Values

PROP_MQ_QMANAGER

public static final String PROP_MQ_QMANAGER

JMS Driver property name used for queue manager

See Also:

Constant Field Values

PROP_MQ_SSL_CIPHER

public static final String PROP_MQ_SSL_CIPHER

JMS Driver property name used for sslCipher

See Also:

Constant Field Values

PROP_MQ_SSL_USE_FLAG

public static final String PROP_MQ_SSL_USE_FLAG

JMS Driver property name used for ssl flag

See Also:

Constant Field Values

mSSL

protected boolean mSSL

Driver properties for SSL

mURL

protected String mURL

Driver properties for Url

mChannel

protected String mChannel

Driver properties for Channel

mQmgr

protected String mQmgr

Driver properties for QueueManager

mHost

protected String mHost

Driver properties for Host

mCipherSuite

protected String mCipherSuite

Driver properties for CipherSuit

mPort

protected int mPort

Driver properties for Port

log

protected JMSDriverLog log

resHash

protected ResourceHash resHash

ResourceHash used for access of the TMS messages

Constructor Detail

IBMMQ

public IBMMQ()

Method Detail

initialize

public void initialize(Hashtable env)
                throws Exception

The initialize(Hastable env) method is passed a java.util.Hashtable object which stores provider-specific parameters, which can be used for connecting to a specific instance of the JMS server. Normally this method would use the supplied parameters to connect to the JMS server and obtain a javax.jms.TopicConnectionFactory object and/or a javax.jms.QueueConnectionFactory object. Then the method would store the object(s) in member variables so that it/they can be later retrieved via the getQueueFactory() and/or the getTopicFactory() method.

Specified by:

initialize in interface JMSDriver

Parameters:

env - Hashtable that holds Driver properties

Throws:

Exception - if JMS Driver cannot be initialized

getQueueFactory

public javax.jms.QueueConnectionFactory getQueueFactory()
                                                 throws Exception

This method retrieves the provider-specific javax.jms.QueueConnectionFactory object

Specified by:

getQueueFactory in interface JMSDriver

Returns:

QueueConnectionFactory object of the JMS Driver

Throws:

Exception - if QueueConnectionFactory cannot be created

getTopicFactory

public javax.jms.TopicConnectionFactory getTopicFactory()
                                                 throws Exception

This method retrieves the provider-specific javax.jms.TopicConnectionFactory object

Specified by:

getTopicFactory in interface JMSDriver

Returns:

TopicConnectionFactory object of the JMS Driver

Throws:

Exception - if TopicConnectionFactory cannot be created

terminate

public void terminate()
               throws Exception

This is a call-back method used to notify the JMS Driver so it could clean any used resources. This method should be used in very rare cases.

Specified by:

terminate in interface JMSDriver

Throws:

Exception - if error while terminating occurs.