MQSeries.net :: View topic

munden101 · Posted: Thu Jun 22, 2006 7:19 am Post subject: JMS COA/COD

How do I implement COA and COD in JMS?

Using MQ API it would be coded like this

Requesting report

MQMessage msg = new MQMessage();
msg.writeString(â€œHello World!â€);
msg.report = MQC.MQRO_EXCEPTION | MQC.MQRO_COA;
queue.put(msg);

Receiving the report:
replyQ = qmgr.accessQueue(qName, openOptions);
MQMessage msg = new MQMessage();
replyQ.get(msg);
if (msg.feedback == MQC.MQFB_COA){
message arrived on target queue
}

Now how do I do this in JMS? Hereâ€™s my code.

InitialContext context = new InitialContext(p);

QueueConnectionFactory qConnectionFactory = (QueueConnectionFactory) context.lookup(connectionFactoryJNDI);

Queue queue = (Queue) context.lookup(queueJNDI);

qConnection = qConnectionFactory.createQueueConnection();

qSession = qConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

QueueSender sender = qSession.createSender(queue);

TextMessage message = qSession.createTextMessage();

message.setText(messageToSend);
sender.send(message);

Queue ReplyToqueue = (Queue) context.lookup("jms/TMResponseQueue");
message.setJMSReplyTo(ReplyToqueue);

sender.close();
qSession.close();
qConnection.close();

Thanks