MQSeries.net :: View topic - Msgs not getting picked up after a while...

newtomq22 · Posted: Fri Aug 12, 2005 1:18 pm Post subject:

Hi,

I am new in terms of mq design and performance issues and i am having this problem where the msgs stop being processed after a while..( they just stay there is the inbound q).. This is someone else's code and i cannot figure out what the problem is. When the server starts the msgs get processed fine but after a few days/weeks the application totally stops processing the msgs and the msgs just keep piling on the q. I don't see any error msgs or anything which could help. The way it's been implemented is that on the server start up a servlet starts a scheduled job.
=======================================
timerReceiver = new Timer();
timerReceiver.schedule(new XMLMsgReceiver(), secXmlMsgsReceiveInitialDelay * 1000, secXmlMsgsReceiveInterval * 1000);
=========================================

and the run() method of this class "XMLMsgReceiver" basically has this
=========================================
if(!XMLMsgReceiver.isRunning) {
debug("starting the MQ listener ");
this.startListener();
}
else
debug("MQ listener is already UP");
=========================================

calls startListener() method which has the following code
==========================================
XMLMsgReceiver.isRunning = true;
QueueConnection connection = null;
QueueSession session = null;

try {
Context context = new InitialContext();

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

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

connection = factory.createQueueConnection();

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

QueueReceiver receiver = session.createReceiver(queue);

connection.start();
Message m = null;

int counter = 0;
while (true) {
counter++;
try{

m = receiver.receive(1);
if (m == null)
break;

isMsgReceived = true;

if (m instanceof TextMessage) {
processMessage(m);
}
else
SchLogger.MQ.debug("Strange...not a text message " + m);

}catch(Exception e){
SchLogger.MQ.info("Exception thrown in startListener() method " + e);
}

if(counter == 500) {
SchLogger.MQ.debug("committing after 500");
try {
session.commit();
} catch (Exception e1) {
e1.printStackTrace();
}
counter = 0;
}
}

} catch (Throwable je) {

je.printStackTrace();

} finally {
if(session != null){
try {
session.commit();
session.close();
} catch (JMSException ignored) {
}
session = null;
}
if (connection != null) {

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

}
XMLMsgReceiver.isRunning = false;

}

Please advice!! If you can direct me to some docs which could help me resolving this issue that would also be great!!!

TIA,