svn commit: r1599350 - /uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java

[cw...@apache.org]

Author: cwiklik
Date: Mon Jun  2 20:33:44 2014
New Revision: 1599350

URL: http://svn.apache.org/r1599350
Log:
UIMA-3844 ignore messages arriving while the client is in stopping state

Modified:
    uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java

Modified: uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java?rev=1599350&r1=1599349&r2=1599350&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java (original)
+++ uima/uima-as/trunk/uimaj-as-jms/src/main/java/org/apache/uima/adapter/jms/client/BaseUIMAAsynchronousEngineCommon_impl.java Mon Jun  2 20:33:44 2014
@@ -1960,6 +1960,9 @@ public abstract class BaseUIMAAsynchrono
    * 
    */
   public void onMessage(final Message message) {
+	  if ( !this.running) {
+		  return;    // ignore the message if the client is stopping
+	  }
     // Process message in a separate thread. Previously the message was processed in ActiveMQ dispatch thread.
     // This onMessage() method is called by ActiveMQ code from a critical region protected with a lock. The lock 
     // is only released if this method returns. Running in a dispatch thread caused a hang when an application