MQSeries.net :: View topic

newtomq22 · Posted: Mon May 02, 2005 11:16 am Post subject:

Hi,

I am using WAS/MQ and JMS as the api. I am an inbound queue and an error inbound queue. I receive the message off the error q and just log it to a file. From th inbound queue i get the message, try to process it , if there is an exception thrown i log it to the rejected message log. It seems that the messages which throw an exception are getting thrown back to the queue.
Do i have to commit the session every time i process/reject a message?
Following is the code snippet
try {
Context context = new InitialContext();

QueueConnectionFactory factory =
(QueueConnectionFactory) context.lookup(
MsgConstants.QUEUE_CONNECTION_FACTORY_NAME);

queue = (Queue) context.lookup(MsgConstants.INBOUND_QUEUE_NAME);
Queue errorQueue = (Queue) context.lookup(MsgConstants.INBOUND_ERROR_QUEUE_NAME);

connection = factory.createQueueConnection();

session =
connection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);

receiver = session.createReceiver(queue);
QueueReceiver errorReceiver = session.createReceiver(errorQueue);

connection.start();
while (true) {
Message m = receiver.receive(1);

Message errorMsg = errorReceiver.receive(1);

if(errorMsg != null) {
if(errorMsg instanceof JMSBytesMessage) {

bytesMsg = (JMSBytesMessage) errorMsg;

byte[] myBytes = new byte[1500];

int i = bytesMsg.readBytes(myBytes);
System.out.println("string message " + new String(myBytes));

MsgLogger.logRejectedMsg(new String(myBytes));
}
else if(errorMsg instanceof TextMessage) {

MsgLogger.logRejectedMsg(((TextMessage) errorMsg).getText());

}
}

if (m != null) {
if (m instanceof TextMessage) {
processMessage(m);
message = (TextMessage) m;
}
} else {
break;
}
}
session.commit();
} catch (Exception je) {

je.printStackTrace();

} finally {

if (connection != null) {

try {
connection.close();
} catch (Exception e) {
e.printStackTrace();
}

}

}

}

and the processMessage(m) basically does this
try {

xmlMsg = ((TextMessage) msg).getText();
MsgLogger.logRecvMsg(xmlMsg);

SchMsgDigester schDigester = new SchMsgDigester();
Object msgObj = schDigester.digest(xmlMsg);
ProcessXmlMsg pxm = new ProcessXmlMsgImpl();
pxm.processMsg(msgObj);

} catch (Exception t) {

StringWriter sw = new StringWriter();
PrintWriter pw = new PrintWriter(sw);
t.printStackTrace(pw);

StringBuffer sb = new StringBuffer("\n\nRejected :");
sb.append(sw.toString());
sb.append(" ** ");
sb.append(xmlMsg);
MsgLogger.logRejectedMsg(sb.toString());

}