MQSeries.net :: View topic

swat · Posted: Wed Jun 28, 2006 3:27 pm Post subject:

Hi,

I am trying to set the correlation id, but when I browse the message in a Q it shows me the truncated value in correlation identifier in MQ. For ex if I am passing correlation ID = 414d5120737761746565202020202020d9cfa044200c9902, the message correlation id that gets set is 414d51207377617465652020.

I want the exact correlation id to be posted. Can u please help me in this regard.

My Program is -

import com.ibm.mq.*;
import java.io.*;

public class Sender {

private static MQQueueManager qMgr;

public Sender() {
super();
}

public static void main(String args[]) {
try {
if (args.length < 1) {
System.out.println("Missing queue name: "
+ "Sender <queue name> <qmgr name (optional)>");
} else {
System.out.println("Sender started...");
// create a new instance of the sample program
Sender Sender = new Sender();
//qMgr = new MQQueueManager(args[1]);
qMgr = new MQQueueManager("swatee");
int openOptions = MQC.MQOO_OUTPUT;
MQQueue q =
qMgr.accessQueue("ivrinqueue", openOptions, null, null, null);
// call method to send messages
try {
// Define a MQ message buffer
MQMessage mBuf = new MQMessage();
// create message options
MQPutMessageOptions pmo = new MQPutMessageOptions();
// accept defaults
pmo.options = MQC.MQPMO_NONE; // use defaults
System.out.println("Enter text to send, blank line to exit");
String xml = "<?xml version='1.0'?><BookCatalogue xmlns='http://www.publishing.org' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xsi:schemaLocation='http://www.publishing.org BookCatalogue.xsd'><Book><Title>Illusions The Adventures of a Reluctant Messiah</Title><Author>Richard Bach</Author><Date>1977</Date><ISBN>0-440-34319-4</ISBN><Publisher>Dell Publishing Co.</Publisher></Book></BookCatalogue>";
InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);
String runShow = xml;
System.out.println("dkkdklo");
String co = args[0];
System.out.println("* please do not use *" + co);
do {
runShow = br.readLine();
if (runShow.length() > 0) {
mBuf.clearMessage(); // reset the buffer
mBuf.correlationId = co.getBytes(); // set correlationId
mBuf.messageId = MQC.MQMI_NONE; // set messageId
mBuf.writeString(runShow); // set actual message
System.out.println("--> writing message to queue");
q.put(mBuf, pmo); // put the message out on the queue
}
} while (runShow.length() > 0);
} catch (MQException ex) {
System.out.println("MQ exception occurred : Completion code "
+ ex.completionCode
+ " Reason code "
+ ex.reasonCode);
} catch (java.io.IOException ex) {
System.out.println(
"An error occurred reading from message buffer: " + ex);
}

// clean up connection
q.close();
qMgr.disconnect();
System.out.println("Sender ended...");
}

} catch (MQException ex) {
System.out.println(
"WMQ exception occurred : Completion code "
+ ex.completionCode
+ " Reason code "
+ ex.reasonCode);
}
}
}

Thanks and regards
Swat