MQSeries.net :: View topic

richdedeyan · Posted: Fri Apr 26, 2002 1:00 pm Post subject:

Hi All,

I am sending messages to MQSeries connected from to a mainframe on one queue and trying to read back the response on another queue.

I have set the timeout interval to 2000ms. When I send the message, then wait, I don't get any message back until I rerun my program. No matter how high I set the timeout, I still cannot read from the queue right away. I am thinking it is how I set the options in my program. Can anyone help?

Thanks,
Rich

int openReceiveOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING ;

// Create the sender and receiver queues
mqSenderQueue = mqQueueManager.accessQueue(sendQueueName,openSendOptions);
mqReceiverQueue = mqQueueManager.accessQueue(receiveQueueName,openReceiveOptions);

public void receiveMQMessage() throws MQException, IOException, InterruptedException {
System.out.println("Receiving Message");

// Create the receive message and set the correlation id to match the logged in user
MQMessage receiveMsg = new MQMessage();
receiveMsg.characterSet = 500;
String corrId = "richd";

receiveMsg.correlationId=corrId.getBytes();

MQGetMessageOptions gmo = new MQGetMessageOptions();

// Get the messages that match the correlation id
gmo.matchOptions=MQC.MQMO_MATCH_CORREL_ID;
gmo.options = MQC.MQGMO_FAIL_IF_QUIESCING;
gmo.options = gmo.options + MQC.MQGMO_WAIT ;
gmo.waitInterval=3000;

mqReceiverQueue.get(receiveMsg,gmo);
String msgText=null;

msgText = receiveMsg.readLine();
System.out.println("Got Message: "+msgText);

}