MQSeries.net :: View topic

masteringmq · Posted: Mon Oct 20, 2008 2:14 am Post subject:

I wrote the code below to put and retrieve messages from a queue. The messages will be put on a remote queue on QM1 and will travel to QM5 local queue QM1.RQSTIN. I have 5 different front end interface build using the java programming language. Each interface will talk to QM1. Now how does the application retrieving the messages in QM5 know which message belongs to which interface and how does the receiving application retrieve all messages associated with a particular interface?. Do I set the correlation ID for the messages on the sending application and at the receiving end retrieve the messages using the correlation ID?. But then how does the receiving application know the correlation ID used by the sending application?.

import com.ibm.mq.*;

public class MQSample
{
private String qManager = "QM1";

private MQQueueManager qMgr;

public static void main(String args[])
{
new MQSample();
}

public MQSample()
{
try
{
//qMgr = new MQQueueManager(qManager);
//int openOptions = MQC.MQOO_OUTPUT ;
//MQQueue MQ1_RQSTIN = qMgr.accessQueue("QM1.RQSTIN",openOptions);
//MQMessage hello_world = new MQMessage();
//hello_world.writeUTF("Hello World!");
//MQPutMessageOptions pmo = new MQPutMessageOptions();
//MQ1_RQSTIN.put(hello_world,pmo);

qMgr = new MQQueueManager("QM5");
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF ;
MQQueue MQ1_RQSTIN = qMgr.accessQueue("QM1.RQSTIN",openOptions);
MQMessage retrievedMessage = new MQMessage();
//retrievedMessage.messageId = hello_world.messageId;
MQGetMessageOptions gmo = new MQGetMessageOptions();
MQ1_RQSTIN.get(retrievedMessage,gmo);
String msg = retrievedMessage.readUTF();
System.out.println(msg);

MQ1_RQSTIN.close();
qMgr.disconnect();

}
catch (MQException ex)
{
System.out.println("A WebSphere MQ error occurred : Completion code " + ex.completionCode + " Reason code " + ex.reasonCode);
}
catch (java.io.IOException ex)
{
System.out.println("An error occurred whilst writing to the message buffer: " + ex);
}
}
}