MQSeries.net :: View topic

rbreault · Posted: Wed Feb 14, 2007 10:52 am Post subject: message get

I am trying to get messages off a queue which I can do just fine with the following code. I want to seperate these messages before I write them to a files how would I do that here is my code when I look at the console I see them all.

package com.arkona.mq.client;

import com.ibm.mq.*;

public class MQClntPut {

public static void main(final String args[]) {

final int openOptions = MQC.MQOO_INPUT_SHARED;

final String qsystemName = "arkdev";
final String queueManagerName = "ARKDEV.QUEUE.MANAGER";
final String queueName = "ROB.IN.QUEUE";

MQEnvironment.hostname = (qsystemName);
MQEnvironment.channel = ("SYSTEM.ADMIN.SVRCONN");
MQEnvironment.port = 1414;

MQEnvironment.disableTracing ();
MQException.log = null;

MQQueueManager qMgr = null;

try {
qMgr = new MQQueueManager(queueManagerName);
} catch (MQException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
System.out.println();

MQQueue inputQueue = null;
try {
inputQueue = qMgr.accessQueue(queueName, openOptions, null, null,
null);
} catch (MQException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
System.out.println("MQ Open Occurred");

final MQMessage msgData = new MQMessage();
final MQGetMessageOptions gmo = new MQGetMessageOptions();

gmo.options = MQC.MQGMO_NO_WAIT + MQC.MQGMO_SYNCPOINT;
gmo.waitInterval = 15000;

boolean Done = false;
while (!Done) {
try {
msgData.messageId = MQC.MQMI_NONE;
msgData.correlationId = MQC.MQCI_NONE;
inputQueue.get(msgData, gmo);
System.out.println("MQ Get Occurred");

final int totalMsgLength = msgData.getTotalMessageLength();
System.out.println("Total Message Length: " + totalMsgLength);

final byte[] strData = new byte[totalMsgLength];
msgData.readFully(strData, 0, totalMsgLength);
System.out.println("Message Read: " + new String(strData));
qMgr.commit();
} catch (final MQException ex) {
System.out.println("MQ Queue Empty");
Done = true;
try {
qMgr.backout();
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (final java.io.IOException ex) {
System.out.println("An error occurred while "
+ "writing the message buffer " + ex);
Done = true;
try {
qMgr.backout();
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}
try {
inputQueue.close();
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("MQ Close occurred");
try {
qMgr.disconnect();
} catch (MQException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("MQ Disconnect occurred");

System.exit(0);
}
}