MQSeries.net :: View topic

dsmq · Posted: Thu Jul 07, 2005 1:40 pm Post subject:

Hi

I am trying to read messages from queue .but i am getting always only one message . its reading only one message at a time , instead of all messages

i am using following code

import com.ibm.mq.*;
import java.util.Hashtable;

public class GetMessage {

private String qManager = "JMSSVR"; // define name of queuemanager to connect to.
private MQQueueManager qMgr; // define a queue managerobject
boolean EOM = false;

public static void main(String args[]){
GetMessage msg = new GetMessage();
}
public GetMessage() {

try {

// Set up MQSeries environment
MQEnvironment.hostname = "abcd";
MQEnvironment.channel = "SYSTEM.DEF.SVRCONN";

//Create a connection to the queue manager
qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open...
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF| MQC.MQGMO_FAIL_IF_QUIESCING | MQC.MQOO_OUTPUT;

// and the open options...
MQQueue queue = qMgr.accessQueue("TEST",
openOptions,
null,
null,
null);

MQMessage msg1 = new MQMessage();
msg1.writeUTF("Message with Message Id!");

// specify the message options...

MQPutMessageOptions pmo1 = new MQPutMessageOptions(); // same as MQPMO_DEFAULT
queue.put(msg1,pmo1);

//For message 2
MQMessage msg2 = new MQMessage();
// msg2.correlationId = msg1.messageId;
msg2.writeUTF("message with Correlation Id!");
MQPutMessageOptions pmo2 = new MQPutMessageOptions();
// put the message on the queue
queue.put(msg2,pmo2);

// get the message back again...
MQMessage getMessage = new MQMessage();
//retrievedMessage.messageId = msg2.messageId;

MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = MQC.MQGMO_NO_WAIT | MQC.MQGMO_FAIL_IF_QUIESCING;

do{
queue.get(getMessage, gmo);
String msgText = getMessage.readString(getMessage.getMessageLength());
System.out.println("The message is: " + msgText);

} while(!EOM);

queue.close(); // Close the queue...
qMgr.disconnect(); // Disconnect from the queue manager
} catch (MQException mqe) {
System.out.println("An MQSeries error occurred : Completion code " +
mqe.completionCode + " Reason code " + mqe.reasonCode);
if (mqe.reasonCode != 2033) {
System.out.println("MQ Error: " + mqe.getMessage());
}
if (mqe.reasonCode == 2033) {
System.out.println("All messages read.");
EOM = true;
}
} catch (java.io.IOException ex) {
System.out.println("An error occurred whilst writing to the message buffer: " + ex);
EOM = true;
}
}
}

pls let me know where i am going wrong