Author: cwiklik Date: Wed Feb 16 18:07:20 2011 New Revision: 1071341 URL: http://svn.apache.org/viewvc?rev=1071341&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/error/handler/ProcessCasErrorHandler.java Modified: uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/error/handler/ProcessCasErrorHandler.java URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/error/handler/ProcessCasErrorHandler.java?rev=1071341&r1=1071340&r2=1071341&view=diff ============================================================================== --- uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/error/handler/ProcessCasErrorHandler.java (original) +++ uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/error/handler/ProcessCasErrorHandler.java Wed Feb 16 18:07:20 2011 @@ -633,6 +633,9 @@ public class ProcessCasErrorHandler exte // String cmCasReferenceId = cacheEntry.getRemoteCMCasReferenceId(); // If the Cas Multiplier is remote send a request to free a CAS with a given cas id if (cmEndpoint != null && cmEndpoint.isCasMultiplier() && cmEndpoint.isRemote()) { + cmEndpoint.setReplyEndpoint(true); + cmEndpoint.setIsCasMultiplier(true); + cmEndpoint.setFreeCasEndpoint(true); aController.getOutputChannel().sendRequest(AsynchAEMessage.ReleaseCAS, cacheEntry.getCasReferenceId(), cmEndpoint); }