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:22:11 UTC
svn commit: r790328 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java
Author: cwiklik
Date: Wed Jul 1 19:22:11 2009
New Revision: 790328
URL: http://svn.apache.org/viewvc?rev=790328&view=rev
Log:
UIMA-1391 Modified stopCasMultiplier to use FreeCas queue from the cache instead of a delegate object
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java?rev=790328&r1=790327&r2=790328&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/BaseAnalysisEngineController.java Wed Jul 1 19:22:11 2009
@@ -2075,17 +2075,17 @@
if ( casMultiplier.getEndpoint().isRemote()) {
// Fetch the endpoint where the Free CAS notification need to go. We use this
// queue to send Stop messages.
- Endpoint freeCasNotificationEndpoint = casMultiplier.getNotificationEndpoint();
+ Endpoint freeCasNotificationEndpoint = casEntry.getFreeCasNotificationEndpoint();
if (freeCasNotificationEndpoint != null ) {
freeCasNotificationEndpoint.setCommand(AsynchAEMessage.Stop);
getOutputChannel().sendRequest(AsynchAEMessage.Stop, aCasReferenceId, freeCasNotificationEndpoint);
}
- System.out.println(">>> Controller:"+getComponentName()+" Stopping Remote Delegate Cas Multiplier:"+casMultiplier.getKey()+" Stopping CM From Generating More CASes from CAS: "+aCasReferenceId);
+ System.out.println(">>> Instance Hashcode:"+hashCode()+" Controller:"+getComponentName()+" Stopping Remote Delegate Cas Multiplier:"+casMultiplier.getKey()+" Stopping CM From Generating More CASes from CAS: "+aCasReferenceId);
if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO) ) {
UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, getClass().getName(), "stopCasMultiplier", UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE, "UIMAEE_stopping_remote_cm_INFO", new Object[] { getComponentName(), casMultiplier.getComponentName(),aCasReferenceId });
}
} else {
- System.out.println(">>> Controller:"+getComponentName()+" Stopping Collocated Delegate Cas Multiplier:"+casMultiplier.getKey());
+ System.out.println(">>> Instance Hashcode:"+hashCode()+" Controller:"+getComponentName()+" Stopping Collocated Delegate Cas Multiplier:"+casMultiplier.getKey());
AnalysisEngineController cm = getCasMultiplierController(casMultiplier.getKey());
cm.addAbortedCasReferenceId(aCasReferenceId);
}