com.ibm.di.plugin.pwstore.jms.driver
Class IBMMQe

java.lang.Object
  extended by com.ibm.di.systemqueue.driver.IBMMQe
      extended by com.ibm.di.plugin.pwstore.jms.driver.IBMMQe
All Implemented Interfaces:
JMSDriver

public class IBMMQe
extends IBMMQe

The MQe JMS Driver implementation. It initialize the JMS Driver and provides specific way for obtaining JMS QueueConnectionFactory. MQe is limited for only one QueueConnectionFactory at a JVM so the Driver creates only one QueueConnectionFactory.


Field Summary
static String PROP_NOTIFICATION_PORT
           
 
Fields inherited from class com.ibm.di.systemqueue.driver.IBMMQe
log, MQE_FILE_INI, MQE_JMS_BROKER, resHash
 
Fields inherited from interface com.ibm.di.systemqueue.driver.JMSDriver
ENVIRONMENT_LOG, JMS_DRIVER_TMS_FILE
 
Constructor Summary
IBMMQe()
           
 
Method Summary
 javax.jms.QueueConnectionFactory getQueueFactory()
          This method retrieves the provider-specific javax.jms.QueueConnectionFactory 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 com.ibm.di.systemqueue.driver.IBMMQe
getTopicFactory
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

PROP_NOTIFICATION_PORT

public static final String PROP_NOTIFICATION_PORT
See Also:
Constant Field Values
Constructor Detail

IBMMQe

public IBMMQe()
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
Overrides:
initialize in class IBMMQe
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
Overrides:
getQueueFactory in class IBMMQe
Returns:
QueueConnectionFactory object of the JMS Driver
Throws:
Exception
Exception - if QueueConnectionFactory cannot be created

terminate

public void terminate()
               throws Exception
Description copied from class: IBMMQe
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
Overrides:
terminate in class IBMMQe
Throws:
Exception - if error while terminating occurs.