com.konakart.mq
Class MqMgr

java.lang.Object
  extended by com.konakart.mq.MqMgr
All Implemented Interfaces:
MqMgrIf

public class MqMgr
extends java.lang.Object
implements MqMgrIf

MqMgrIf - Message Queue Manager Implementation


Field Summary
protected static org.apache.commons.logging.Log log
          the log
 
Constructor Summary
MqMgr()
          Constructor
 
Method Summary
 void postMessageToQueue(MqOptionsIf options)
          Post a message to a specified queue.
 MqResponseIf readMessageFromQueue(MqOptionsIf options)
          Read a single message from a specified queue.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

protected static org.apache.commons.logging.Log log
the log

Constructor Detail

MqMgr

public MqMgr()
      throws java.lang.Exception
Constructor

Throws:
java.lang.Exception
Method Detail

postMessageToQueue

public void postMessageToQueue(MqOptionsIf options)
                        throws KKException
Description copied from interface: MqMgrIf
Post a message to a specified queue. Use the options parameter to define the message text, credentials and the destination queue.

Specified by:
postMessageToQueue in interface MqMgrIf
Parameters:
options - the MQ options
Throws:
KKException

readMessageFromQueue

public MqResponseIf readMessageFromQueue(MqOptionsIf options)
                                  throws KKException
Description copied from interface: MqMgrIf
Read a single message from a specified queue. Use the options parameter to define credentials, a timeout value and the name of the queue to read.

Specified by:
readMessageFromQueue in interface MqMgrIf
Parameters:
options - the MQ options
Returns:
an object describing the response from this call. Usually it will contain the text of the message that was read, but if there was a timeout the message will be null and the timedout attribute will be true.
Throws:
KKException


Copyright © 2011 DS Data Systems UK Ltd.