// 1- Change the status before pushing the messages into the session queue.
setReceiveStatus(ReceiveStatus.CONSUMING_REPLY);
}
try {
ConsumerMessages cm = (ConsumerMessages)reply;
// 2- increment messageCount (synchronized)
messageCount += cm.getMessageCount();
pushMessages(cm);
} catch (StoppedQueueException exc) {
throw new AbortedRequestException();
} catch (JMSException exc) {