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

[cwiklik]

Author: cwiklik
Date: Wed Feb 16 18:06:49 2011
New Revision: 1071339

URL: http://svn.apache.org/viewvc?rev=1071339&view=rev
Log:
UIMA-2055 Modified to work with new/refactored JmsOutputChannel

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

Modified: 
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java
URL: 
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java?rev=1071339&r1=1071338&r2=1071339&view=diff
==============================================================================
--- 
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java
 (original)
+++ 
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/PrimitiveAnalysisEngineController_impl.java
 Wed Feb 16 18:06:49 2011
@@ -400,7 +400,7 @@ public class PrimitiveAnalysisEngineCont
         // Send CPC completion reply back to the client. Use internal 
(non-jms) transport
         
transport.getUimaMessageDispatcher(anEndpoint.getEndpoint()).dispatch(message);
       } else {
-        
getOutputChannel().sendReply(AsynchAEMessage.CollectionProcessComplete, 
anEndpoint);
+        
getOutputChannel().sendReply(AsynchAEMessage.CollectionProcessComplete, 
anEndpoint, null, false);
       }
 
       if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.FINE)) {
@@ -781,7 +781,7 @@ public class PrimitiveAnalysisEngineCont
         }
       } else {
         if (!stopped && !clientUnreachable ) {
-            getOutputChannel().sendReply(aCasReferenceId, anEndpoint);
+            
getOutputChannel().sendReply(getInProcessCache().getCacheEntryForCAS(aCasReferenceId),
 anEndpoint);
         }
 
         inputCASReturned = true;