MQSeries.net :: View topic

jmac · Posted: Mon Oct 08, 2001 11:11 am Post subject:

I am trying to put a message on a queue with a correlation ID, then get the reply message with the same correlation ID. I am not having any luck. My code is basically this:

MQMessage message = new MQMessage();

message.userId = m_strMQUserID;
message.writeString(msgPart1.toString());
if ( m_boolAwaitReply )
{
message.replyToQueueManagerName = m_strQueueManagerReply;
message.replyToQueueName = m_strQueueReply;
m_strCorrelID = "1111111111111111111111111111111111";
message.correlationId = m_strCorrelID.getBytes();
}
MQPutMessageOptions pmo = new MQPutMessageOptions( );
// The SET_IDENTITY_CONTEXT allows you to specify a userid other than
// the logged on user
pmo.options = MQC.MQPMO_SET_IDENTITY_CONTEXT ;

// put the message on the queue
this.xmlQueue.put(message, pmo);

******** Now the get:

MQMessage currentMessage = new MQMessage();
m_strCorrelID = "1111111111111111111111111111111112";
currentMessage.correlationId = m_strCorrelID.getBytes();
MQGetMessageOptions gmo = new MQGetMessageOptions( );
gmo.options = MQC.MQGMO_WAIT;
gmo.waitInterval = MQC.MQWI_UNLIMITED;
mqwfQ.get( currentMessage, gmo );

------------------
As you can see I have intentionally changed the correlid. I would expect that this should now wait forever, since there is no message with that particular correlation ID. IT DOES NOT, I get the reply. Obviously I am doing something silly, I just cant see it.

THANKS

_________________
John McDonald
SYSCOM Inc.
IBM Certified Solutions Expert -
MQSeries Workflow

[ This Message was edited by: jmac on 2001-10-08 12:13 ]

[ This Message was edited by: jmac on 2001-10-08 12:14 ]