|
||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
| SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||
java.lang.Object | +--com.ibm.workflow.upes.MQHandler
The MQHandler encapsulates the MQSeries API to what is needed
by the WFMessageAdapter.
For performance reasons it keeps the handle of opened queues and queue
managers.
| Field Summary | |
private com.ibm.mq.MQQueueManager |
_localQueueManager
The handle of the local queue manager |
private java.util.Hashtable |
_queues4Get
List of queue handles the WFMessageAdapter get messages from |
private java.util.Hashtable |
_queues4Put
List of queue handles the WFMessageAdapter put messages to |
| Constructor Summary | |
MQHandler(java.lang.String queueManagerName)
Opens a new queue manager object and keeps its handle. |
|
| Method Summary | |
boolean |
commit()
Commit the transaction |
com.ibm.mq.MQMessage |
getMessage(java.lang.String queueManagerName,
java.lang.String queueName)
Get a message from an input queue. |
com.ibm.mq.MQMessage |
getMessageNoWait(java.lang.String queueManagerName,
java.lang.String queueName)
Get a message from an input queue. |
com.ibm.mq.MQQueue |
getQueue4Get(java.lang.String queueManagerName,
java.lang.String queueName)
Get a queue handle for a MQSeries GET operation |
com.ibm.mq.MQQueue |
getQueue4Put(java.lang.String queueManagerName,
java.lang.String queueName)
Get a queue handle for a MQSeries PUT operation |
boolean |
putMessage(com.ibm.mq.MQMessage message2Put,
java.lang.String queueManagerName,
java.lang.String queueName)
Put a message into an output queue. |
boolean |
rollback()
Rollback the transaction |
java.lang.String |
transformMessage(com.ibm.mq.MQMessage mq)
Transforms the payload of a MQSeries message into a JAVA string. |
| Methods inherited from class java.lang.Object |
|
| Field Detail |
private com.ibm.mq.MQQueueManager _localQueueManager
private java.util.Hashtable _queues4Put
private java.util.Hashtable _queues4Get
| Constructor Detail |
public MQHandler(java.lang.String queueManagerName)
throws com.ibm.mq.MQException
queueManagerName - The name of the local queue managercom.ibm.mq.MQException - | Method Detail |
public java.lang.String transformMessage(com.ibm.mq.MQMessage mq)
throws java.io.IOException
mq - The MQSeries messagejava.io.IOException -
public com.ibm.mq.MQMessage getMessage(java.lang.String queueManagerName,
java.lang.String queueName)
throws com.ibm.mq.MQException
queueManagerName - The input queue manager namequeueName - The input queue namecom.ibm.mq.MQException -
public com.ibm.mq.MQMessage getMessageNoWait(java.lang.String queueManagerName,
java.lang.String queueName)
throws com.ibm.mq.MQException
queueManagerName - The input queue manager namequeueName - The input queue namecom.ibm.mq.MQException -
public boolean putMessage(com.ibm.mq.MQMessage message2Put,
java.lang.String queueManagerName,
java.lang.String queueName)
throws com.ibm.mq.MQException
message2Put - The MQSeries message to putqueueManagerName - The output/target queue manager namequeueName - The output/target queue namecom.ibm.mq.MQException -
public com.ibm.mq.MQQueue getQueue4Get(java.lang.String queueManagerName,
java.lang.String queueName)
throws com.ibm.mq.MQException
queueManagerName - queueName - com.ibm.mq.MQException -
public com.ibm.mq.MQQueue getQueue4Put(java.lang.String queueManagerName,
java.lang.String queueName)
throws com.ibm.mq.MQException
queueManagerName - queueName - com.ibm.mq.MQException -
public boolean commit()
throws com.ibm.mq.MQException
com.ibm.mq.MQException -
public boolean rollback()
throws com.ibm.mq.MQException
com.ibm.mq.MQException -
|
||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
| SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||