com.ibm.di.systemqueue.driver
Class IBMMB
java.lang.Object
com.ibm.di.systemqueue.driver.IBMMB
- All Implemented Interfaces:
- JMSDriver
- Direct Known Subclasses:
- IBMMB
public class IBMMB
- extends Object
- implements JMSDriver
A MicroBroker JMS Driver responsible for connection to a MicroBroker server
and creating both the QueueConnectionFactore and the TopicConnectionFactory.
FOR INTERNAL USE ONLY! THIS CLASS IS NOT SUPPORTED FOR THE 7.0 or 7.1 RELEASES!
Constructor Summary |
IBMMB()
|
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 |
COPYRIGHT
protected static final String COPYRIGHT
- See Also:
- Constant Field Values
MB_JMS_BROKER
protected static final String MB_JMS_BROKER
- See Also:
- Constant Field Values
MB_DEFAULT_PORT
protected static final int MB_DEFAULT_PORT
- See Also:
- Constant Field Values
url
protected String url
host
protected String host
port
protected int port
log
protected JMSDriverLog log
resHash
protected ResourceHash resHash
IBMMB
public IBMMB()
getQueueFactory
public javax.jms.QueueConnectionFactory getQueueFactory()
throws Exception
- Description copied from interface:
JMSDriver
- This method retrieves the provider-specific
javax.jms.QueueConnectionFactory object
- Specified by:
getQueueFactory
in interface JMSDriver
- Returns:
- The
QueueConnectionFactory
after connecting to the
MicroBroker server.
- Throws:
Exception
- in case the provided during the initialization URL is
incorrect.
getTopicFactory
public javax.jms.TopicConnectionFactory getTopicFactory()
throws Exception
- Description copied from interface:
JMSDriver
- This method retrieves the provider-specific
javax.jms.TopicConnectionFactory object
- Specified by:
getTopicFactory
in interface JMSDriver
- Returns:
- The
TopicConnectionFactory
after connecting to the
MicroBroker server.
- Throws:
Exception
- in case the provided during the initialization URL is
incorrect.
initialize
public void initialize(Hashtable env)
throws Exception
- Description copied from interface:
JMSDriver
- 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
- a hashtable containing configuration parameters used during
the connecting process. This Driver expects only a parameter
with a key MB_JMS_BROKER
and a value that follows
this syntax: <host>:<port> if the port is omitted
the default port 1883 is assumed.
- Throws:
Exception
- in case the the required parameter is not provided or if
the provided URL is not following the specific format.
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.