MQSeries.net :: View topic

vandana · Posted: Mon Dec 10, 2001 11:50 pm Post subject:

I have created a QM(QM_ind7)
with 2 queues ind7_local1 and
ind7_reply_queue.
A java program is triggered when i put the
message in ind7_local1 using amqsput.
the queue initially doesn't contain any
messages.
the java program is given below.
the program gets a message from ind7_local1
and puts it in ind7_reply_queue.
what is the significance of
the foll stmt :
hello_world.correlationId = retrievedMessage.messageId;
the prg puts message the reply queue
even without it?

-------------------------------------
String argqmgr,argqname;
argqmgr = "QM_ind7";
argqname = "ind7_local1";
MQQueueManager qMgr;
MQGetMessageOptions gmo=new MQGetMessageOptions();
gmo.options = MQC.MQGMO_FAIL_IF_QUIESCING | MQC.MQGMO_CONVERT|
MQC.MQGMO_ACCEPT_TRUNCATED_MSG | MQC.MQGMO_WAIT ;
gmo.waitInterval = 10000;
MQPutMessageOptions pmo=new MQPutMessageOptions();

pmo.options = MQC.MQPMO_FAIL_IF_QUIESCING |MQC.MQPMO_NEW_MSG_ID;

int gopenOptions = MQC.MQOO_INPUT_EXCLUSIVE| MQC.MQOO_FAIL_IF_QUIESCING ;

int popenOptions = MQC.MQOO_FAIL_IF_QUIESCING| MQC.MQOO_OUTPUT ;

qMgr = new MQQueueManager(argqmgr);
MQQueue inputqueue= qMgr.accessQueue(argqname, gopenOptions,null,null,null);

MQQueue system_default_local_queue = qMgr.accessQueue("ind7_reply_queue", popenOptions,null,null,null);

// start while loop to read first message and reply, then await additional messages
while (compcode != 0) {
// create the message object to read from the queue
MQMessage retrievedMessage = new MQMessage();
retrievedMessage.format==MQC.MQFMT_STRING; retrievedMessage.messageType =MQC.MQMT_REQUEST;
retrievedMessage.messageId=MQC.MQMI_NONE; retrievedMessage.correlationId=MQC.MQMI_NONE;inputqueue.get(retrievedMessage,gmo,500);
int msgsize=retrievedMessage.getDataLength();
String msgText = retrievedMessage.readString(msgsize); System.out.println("message content is: n" + msgText);
MQMessage hello_world=new MQMessage();
hello_world.format=MQC.MQFMT_STRING;
hello_world.messageType = MQC.MQMT_REPLY;

hello_world.correlationId = retrievedMessage.messageId;
hello_world.writeString(msgText); system_default_local_queue.put(hello_world,pmo);
}

_________________

[ This Message was edited by: vandana on 2001-12-10 23:51 ]