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/07/01 21:20:24 UTC
svn commit: r790325 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Author: cwiklik
Date: Wed Jul 1 19:20:23 2009
New Revision: 790325
URL: http://svn.apache.org/viewvc?rev=790325&view=rev
Log:
UIMA-1391 Modified process() method to use FreeCas queue from the cache instead of Delegate object when sending FreeCas request
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_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/AggregateAnalysisEngineController_impl.java?rev=790325&r1=790324&r2=790325&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java Wed Jul 1 19:20:23 2009
@@ -953,7 +953,8 @@
{
// If the delegate CM is a remote, send a Free CAS notification
if ( delegateCM.getEndpoint().isRemote()) {
- getOutputChannel().sendRequest(AsynchAEMessage.ReleaseCAS, entry.getCasReferenceId(), delegateCM.getNotificationEndpoint());
+ parentCasStateEntry.getFreeCasNotificationEndpoint().setCommand(AsynchAEMessage.Stop);
+ getOutputChannel().sendRequest(AsynchAEMessage.ReleaseCAS, entry.getCasReferenceId(), parentCasStateEntry.getFreeCasNotificationEndpoint());
}
// Check if a request to stop generation of new CASes from the parent of
// this CAS has been sent to the CM. The Delegate object keeps track of