|
||||||||
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 |