When JBoss 5.1.0 server is shutdown and restarted, new messages in a server queue (org.jboss.mq.server.jmx.Queue) are not processed by the QueueReceiver on the client.
Here is a snippet of the client side code that waits for messages:
while (true) {
try {
log.debug("receiving message");
ObjectMessage message = (ObjectMessage) consumer.receive(QUEUE_WAIT_SECONDS * 1000);
if (message != null) {
log.debug("got a message");
return message;
} else {
log.debug("No message found for " + QUEUE_WAIT_SECONDS + " seconds");
}
} catch (InvalidDestinationException ide) {
log.error("Reply queue no longer exists");
} catch (Exception e) {
e.printStackTrace();
log.error(e);
throw e;
}
}
anyone have an idea on this, thanks!