Dave Siracusa [http://community.jboss.org/people/davesiracusa] created the discussion "Message loss during shutdown or JMX stop of JMS Listener" To view the discussion, visit: http://community.jboss.org/message/560276#560276 -------------------------------------------------------------- I'm looking into JMS message loss issues during shutdown.  I enqueued several thousand mesages into an ESB application.  While the messages were being processed I toggle(stop/start) lifecycle state for the jms listeners via JMX in order to simulate shutdown.  I noticed periodic warnings in the serverlog (listing 1).  The final tally indicated message loss.  I believe I found a bug in ESB. Basically when a doStop (JMXConsole) is called it sets state to STOPPING and immediately terminates the executor thread (MessageAwareListener.java). If the thread was currently processing a mesage bad things happen. I use transcated queues and it appears the JMS message transaction evaporates and the message is lost. I added some code to AbstractThreadedManagedLifecycle.java to remedy the issue. AbstractThreadedManagedLifecycle.java --------------------------------------- protected void doStop() throws ManagedLifecycleException { runningLock.lock() ; try { if (isRunning()) { setRunning(ManagedLifecycleThreadStatae.STOPPING) ; } // Dave Siracusa -start if (!waitUntilStopped()) { throw new ManagedLifecycleException("Thread still active!") ; } // Dave Siracusa - end } finally { runningLock.unlock() ; } } MessageAwareListener.java --------------------------- protected void doStop() throws ManagedLifecycleException { super.doStop(); _execService.shutdown() ; } Listing 1 ---------- 2010-09-01 15:04:40,924 WARN [org.jboss.soa.esb.listeners.lifecycle.AbstractThreadedManagedLifecycle] (Thread-200) Unexpected error from doRun() java.util.concurrent.RejectedExecutionException at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecutionThreadPoolExecutor.java:1768) at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658) at org.jboss.soa.esb.listeners.message.MessageAwareListener.waitForEventAndProcess(MessageAwareListener.java:359) at org.jboss.soa.esb.listeners.message.MessageAwareListener.doRun(MessageAwareListener.java:253) at org.jboss.soa.esb.listeners.lifecycle.AbstractThreadedManagedLifecycle.run(AbstractThreadedManagedLifecycle.java:115) at java.lang.Thread.run(Thread.java:619) -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/560276#560276] Start a new discussion in JBoss ESB Development at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]