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!