MQSeries.net :: View topic - 2033 when MQMO_MATCH_CORREL_ID used

HMed · Posted: Sat Sep 18, 2004 9:07 am Post subject:

I have a situation where program1 puts a message on an MQ queue using default msgid and correlationids. I then move the msgid to the correlation id and "000000000000000000000001".getBytes() to the msgid for future matching of the reply.

Program2, a MDB picks up the msgid in JMS format (ascii hex), converts the msgid to integer, using parseint radix, byteshift, bytearray ect. and moves it to the correlationId. It then moves "000000000000000000000001".getBytes() to the msgid and uses MQ classes to send the msg to the reply queue. (ps, I am aware of the prefix JMS puts on the msgid, and that has been taken into account)

At this point, program1 gets the reply message, but is not able to match when using correlationid in the GMO's. It is able to match when not using correlationID in the GMO's. I can display (in ascii hex) the sending msgid after the put (above) and the receiving correlation id after the get, and they are identical.

Here is the code of the put and the get. Does anybody know if I should be using an additional parameter to ensure matching, if I should remove Quiescing, transport or other properties? Any help is truly appreciated.

private final static int MQ_Reply_Queue_Open_Options =
MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING;

private byte[] correlationId = { 1 };

private byte[] messageId;

mqenv = new MQEnvironment();
mqenv.hostname = hostName;
mqenv.channel = channel;
mqenv.port = port;
mqenv.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES);

queueMgr = new MQQueueManager(reqQMgrName);

reqQueue =
queueMgr.accessQueue(
reqQueueName,
MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING,
null,
null,
null);

MQMessage mqmsg = new MQMessage();

mqmsg.replyToQueueManagerName = repQMgrName;
mqmsg.replyToQueueName = repQueueName;

mqmsg.messageType = MQC.MQMT_REQUEST;
mqmsg.format = MQC.MQFMT_STRING;

mqmsg.writeBytes(msg);

MQPutMessageOptions pmo = new MQPutMessageOptions();

pmo.options = MQC.MQPMO_FAIL_IF_QUIESCING;

reqQueue.put(mqmsg, pmo);

correlationId = mqmsg.messageId;

//****************************************************
//**** this code used to verify and display correlationid / msgid
//**** in hex format
//****************************************************

String tmp2 = new String(correlationId);

byte ch = 0x00;
int iz = 0;
String pseudo[] = {"0","1","2","3","4","5","6","7","8","9","A","B","C","D","E","F" };
StringBuffer out1 = new StringBuffer(correlationId.length * 2);

while (iz < correlationId.length) {
ch = (byte) (correlationId[iz] & 0xF0); // Strip off high nibble
ch = (byte) (ch >>> 4); // shift the bits down
ch = (byte) (ch & 0x0F); // must do this is high order bit is on!
out1.append(pseudo[(int) ch]); // convert the nibble to a String Character
ch = (byte) (correlationId[iz] & 0x0F); // Strip off low nibble
out1.append(pseudo[(int) ch]); // convert the nibble to a String Character
iz++;
}
String rslt = new String(out1);

eeobLog.debug("Sent messageId = " + rslt + " returning correlation id should match" );

//****************************************************
//**** this code used to verify and display correlationid / msgid
//**** in hex format
//****************************************************

reqQueue.close();

/**
* This method gets the reply back from mq
*/

byte[] pdfBytes = { 1 };

MQQueueManager repQueMgr = null;

mqenv.properties.put(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT);

repQueMgr = new MQQueueManager(repQMgrName);

repQueue =
repQueMgr.accessQueue(
repQueueName,
MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_BROWSE | MQC.MQOO_INQUIRE,
null,
null,
null);

MQMessage replyMessage = new MQMessage();

MQGetMessageOptions getMsgOptions = new MQGetMessageOptions();

replyMessage.correlationId = correlationId;

replyMessage.messageId = "000000000000000000000001".getBytes();

getMsgOptions.options= MQC.MQMO_MATCH_MSG_ID |
MQC.MQMO_MATCH_CORREL_ID | MQC.MQGMO_WAIT | MQC.MQSEG_ALLOWED;

getMsgOptions.waitInterval=30000;

repQueue.get(replyMessage, getMsgOptions,repQueue.getMaximumMessageLength());

//****************************************************
//**** this code used to verify and display correlationid / msgid
//**** in hex format
//****************************************************

byte ch = 0x00;
int iz = 0;
String pseudo[] = {"0","1","2","3","4","5","6","7","8","9","A","B","C","D","E","F" };
StringBuffer out1 = new StringBuffer( replyMessage.correlationId.length * 2);

while (iz < replyMessage.correlationId.length) {
ch = (byte) ( replyMessage.correlationId[iz] & 0xF0); // Strip off high nibble
ch = (byte) (ch >>> 4); // shift the bits down
ch = (byte) (ch & 0x0F); // must do this is high order bit is on!
out1.append(pseudo[(int) ch]); // convert the nibble to a String Character
ch = (byte) ( replyMessage.correlationId[iz] & 0x0F); // Strip off low nibble
out1.append(pseudo[(int) ch]); // convert the nibble to a String Character
iz++;
}
String rslt = new String(out1);

eeobLog.debug("Recieved correlationId = " + rslt );

//****************************************************
//**** this code used to verify and display correlationid / msgid
//**** in hex format
//****************************************************

//****************************************************
//**** at this point I get the 2033, but if I take out the
//**** MQC.MQMO_MATCH_CORREL_ID I can successfully get msg
//****************************************************

//
replyMessage.readFully(pdfBytes);
repQueue.close();

repQueMgr.disconnect();
repQueMgr.close();