You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/04/10 16:13:06 UTC

svn commit: r763941 - /incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java

Author: cwiklik
Date: Fri Apr 10 14:13:05 2009
New Revision: 763941

URL: http://svn.apache.org/viewvc?rev=763941&view=rev
Log:
UIMA-1109 Modified to support orderly shutdown of Uima AS service

Modified:
    incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java

Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java?rev=763941&r1=763940&r2=763941&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java Fri Apr 10 14:13:05 2009
@@ -593,7 +593,7 @@
 	         }
 					getInProcessCache().releaseCASesProducedFromInputCAS(aCasReferenceId);
 				}
-				else if ( inputCASReturned )
+				else if ( inputCASReturned && isTopLevelComponent() )
 				{
 					//	Remove input CAS cache entry if the CAS has been sent to the client
 					dropCAS(aCasReferenceId, true);
@@ -717,13 +717,11 @@
 	{
 	  System.out.println(">>>>> Stopping Controller:"+getComponentName());
 		super.stop();
-		stopInputChannel();
 		if ( aeInstancePool != null )
 		{
 			try
 			{
 				aeInstancePool.destroy();
-	      stopTransportLayer();
 			}
 			catch( Exception e){ e.printStackTrace();}
 		}