Wsrtjtyk

Based on multiple analysis through google I created a Java based MQ JMS client . Basically I am new to MQ and
got few doubts whether the code which I created will work properly for the below Request and Reply.

Request and Reply message:

  REQUEST(SERVICE,10,CREATE_TEST,MSGID,15,FGD024049364194,TESTID,4,

USMQ,SRID,8,#MSTD,EMPID,5,8104,LOC,4,QR,AT-RP,4,QR,RTR,

7,2624931,UVT-ORD-SYS,4,CHAT,UVT-REQ,1,S,UVT-ORD,9,QT0046259,VTRD-2)RETURN();





REPLY(MSGID,15,FGD024049364194,DESTID,4,TRMQ,EMPID,5,8104,LOC,4,RTR,VTCT,0,

,UVT-DELCMNT,0,,UVT-DEL-REA,0,,UVT-DLVRY-FLG,1,N,UVT-DLVRY-STUS,1,

10,CREATE_TEST,TKT-NBR,7,2624931,USERID,8,#AMSATD)

MESSAGE(INFO,TEST-GROUP,5,PS,INFO,UVTTS,49,+00 INVALID/NORMAL,VICE,62,

00000 UPDATE SUCCESSFUL 3734931,INFO,STSUTITMEOUT,60,+0000 INVALID/OUT OF WORLD.); 

My requirement is store the above Request message in a table in the oracle database and I want to
read the message from the table and put in the Queue which will interact the other system(third party).

The other systeme will reply the message as above and I need to store the reply message along with the Message Id in the same read table.

Please clarify My doubt and correct me what i need to change in the code in case wrong:

1) In the Request there is a MSG Id availbale and also in the Reply there is a messge ID. How it will works in my scenario
I read in some site "like a MessgeID is automatically generated for you, and you can't change that behaviour".

so in my scenario as in the below code what message id will get.Is it correct?

2) When I read the message do I get complete above Reply message or only the Message mentioned in Reply.

Please clarify my above doubts:

code for Write method:

public  void write(List<Createbean> createbeanList)  throws MQException

{



    try {



        MQQueueManager qMgr = new MQQueueManager(qManager, env); 



        // Set up the options on the queue we wish to open 

        int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;



        // Now specify the queue that we wish to open and the open options

        log.info("Accessing queue: "+qName);

        MQQueue queue = qMgr.accessQueue(qName, openOptions);



        // Define a simple WebSphere MQ Message ...

        MQMessage msg = new MQMessage();

        msg.format = MQC.MQFMT_STRING;

        msg.format = MQC.MQFMT_STRING;

        msg.feedback = MQC.MQFB_NONE;

        msg.messageType = MQC.MQMT_DATAGRAM;





        for (Createbean createBean : createbeanList) {



            String createMessage =createBean.getMessage();



            msg.writeString(createMessage);

        }





        // Specify the default put message options

        MQPutMessageOptions pmo = new MQPutMessageOptions();



        // Put the message to the queue

        queue.put(msg, pmo);



        // Close the queue

        queue.close();



        // Disconnect from the QueueManager

        // logger.debug(CLASS, methodName, "Disconnecting from the Queue

        // Manager");

        qMgr.disconnect();

        // logger.debug(CLASS, methodName, "Done!");

Read method:

            private void read() throws MQException

            {



                int openOptions = MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_INPUT_SHARED | MQC.MQOO_BROWSE;  



                MQQueue queue = _queueManager.accessQueue( inputQName,

                        openOptions,

                        null, // default q manager

                        null, // no dynamic q name

                        null ); // no alternate user id



                log.info("MQRead v1.0 connected.n");



                int depth = queue.getCurrentDepth();

                log.info("Current depth: " + depth + "n");

                if (depth == 0)

                {

                    return;

                }



                MQGetMessageOptions getOptions = new MQGetMessageOptions();

                //getOptions.options = MQC.MQGMO_NO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING + MQC.MQGMO_CONVERT;



                getOptions.options=MQC.MQGMO_WAIT | MQC.MQGMO_BROWSE_FIRST;

                getOptions.matchOptions=MQC.MQMO_NONE;

                getOptions.waitInterval=5000;

                long messageCount = 0;

                boolean thereAreMessages=true;

                while(thereAreMessages)

                {

                    if(messageCount  >0){

                    MQMessage message = new MQMessage();

                    try

                    {

                        message.messageId     = MQC.MQMI_NONE;

                        queue.get(message, getOptions);



                        log.info("  MsgId : ");

                      String messageID=  dumpHexId(message.messageId);



                        String msg = message.readString(message.getMessageLength()); 



                        log.info("Browsed message: " + msg);

                        log.info("Actually get message?");



                        byte b = new byte[message.getMessageLength()];

                        message.readFully(b);



                        createDAO rmdao  = new createDAO();



                        rmdao.updateCreate(new String(b),messageID);



                        log.info(new String(b));

                        message.clearMessage();



                         /************************************************/

                           /* Reset the options to browse the next message */

                           /************************************************/

                        getOptions.options= MQC.MQGMO_WAIT | MQC.MQGMO_BROWSE_NEXT;

                    }

Thanks in advance