MQSeries.net :: View topic

alfia_786 · Posted: Wed Nov 14, 2007 9:01 am Post subject:

Hi,
Plz somebody help me

I am trying a very simple send and receive program which is not working,it gives a 2033 reason code and if i try to write a program to just print the contents of the reply queue it does not have the message that was sent recently.If I dont get the message that I am sending ,does that mean the message was not sent,but the put method is called and no exceptions are thrown..plz help..here is my code:

this is for sending :
--------------------------------------------------------------
qMgr = new MQQueueManager(qManager);
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT
| MQC.MQOO_INQUIRE ;
MQQueue sendQueue = qMgr.accessQueue(queuename, openOptions);
MQPutMessageOptions pmo = new MQPutMessageOptions();
MQMessage regrenewal = new MQMessage();
regrenewal.format = MQC.MQFMT_STRING;
regrenewal.replyToQueueName = replyq;
regrenewal.writeString("sending data");
sendQueue.put(regrenewal, pmo);
out.println("msg put the message id is"+regrenewal.messageId);
qMgr.commit();
sendQueue.close();
----------------------------------------------------------------------

this is for receiving

-----------------------------------------------------------------------
qMgr = new MQQueueManager(qManager);
int openOptions = MQC.MQOO_OUTPUT
| // for put access
MQC.MQOO_INQUIRE
| // check q depth
MQC.MQOO_INPUT_AS_Q_DEF
| // for get access
MQC.MQOO_FAIL_IF_QUIESCING
|
MQC.MQOO_BROWSE;
MQQueue outQ = qMgr.accessQueue(replyq,openOptions);
int curDepth = outQ.getCurrentDepth();
int maxLength = outQ.getMaximumMessageLength();
out.println("Current depth: " + curDepth);
MQMessage myMessage = new MQMessage();
myMessage.format = MQC.MQFMT_STRING;
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = MQC.MQGMO_BROWSE_FIRST;
outQ.get(myMessage, gmo);
out.println(" about to read msg");
tring msgText = myMessage.readString(myMessage.getMessageLength());
out.println("The message is: " + msgText);
qMgr.commit();
outQ.close();
qMgr.disconnect();