Author: cwiklik
Date: Mon Mar 7 16:34:08 2011
New Revision: 1078842
URL: http://svn.apache.org/viewvc?rev=1078842&view=rev
Log:
UIMA-2084 - modified dumpState()
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
URL:
http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java?rev=1078842&r1=1078841&r2=1078842&view=diff
==============================================================================
---
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
(original)
+++
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Mon Mar 7 16:34:08 2011
@@ -3091,38 +3091,51 @@ public class AggregateAnalysisEngineCont
throw new Exception("Controller:"+getComponentName()+" Unable to change
state of colocated delegate");
}
}
+
- public void dumpState() {
- StringBuffer remoteDelegates = new StringBuffer("------------
"+getComponentName()+" Remote Delegates:\n\t");
- StringBuffer colocatedDelegates = new StringBuffer("------------
"+getComponentName()+" Colocated Delegates:\n\t");
+ public void dumpState(StringBuffer buffer, String lbl1) {
+ StringBuffer delegates = new StringBuffer();
+ boolean first = false;
+ if ( buffer.length() == 0) {
+ first = true;
+ delegates.append("\n"+lbl1+getComponentName()+" Delegates:");
+ }
+ int remotes=0;
synchronized(destinationMap) {
Set set = destinationMap.entrySet();
for (Iterator it = set.iterator(); it.hasNext();) {
+ delegates.append("\n");
Map.Entry entry = (Map.Entry) it.next();
Endpoint endpoint = (Endpoint) entry.getValue();
if ( endpoint.isRemote() ) {
if ( endpoint.isInitialized() ) {
- remoteDelegates.append("Delegate:"+endpoint.getDelegateKey()+"
State: "+ServiceState.RUNNING);
+ delegates.append(lbl1+lbl1+"Remote
Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
} else {
- remoteDelegates.append("Delegate:"+endpoint.getDelegateKey()+"
State: "+ServiceState.INITIALIZING);
+ delegates.append(lbl1+lbl1+"Remote
Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
}
- remoteDelegates.append("\n\t");
} else {
if ( endpoint.isInitialized() ) {
- colocatedDelegates.append("Delegate:"+endpoint.getDelegateKey()+"
State: "+ServiceState.RUNNING);
+ delegates.append(lbl1+lbl1+"Co-located
Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
} else {
- colocatedDelegates.append("Delegate:"+endpoint.getDelegateKey()+"
State: "+ServiceState.INITIALIZING);
+ delegates.append(lbl1+lbl1+"Co-located
Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ }
+ synchronized(childControllerList) {
+ if ( childControllerList.size() > 0 ) {
+ for( AnalysisEngineController childController :
childControllerList ) {
+ if (
endpoint.getDelegateKey().equals(childController.getKey()) &&
!childController.isPrimitive()) {
+ buffer.append(delegates.toString());
+ childController.dumpState(buffer,lbl1+lbl1);
+ delegates.setLength(0);
+ }
+ }
+ }
}
- colocatedDelegates.append("\n\t");
}
}
}
- UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO,
CLASS_NAME.getName(), "dumpState",
- UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE,
"UIMAEE_service_state__INFO",
- new Object[] {
"\n"+remoteDelegates.toString()+"\n"+colocatedDelegates.toString()});
-
+ buffer.append(delegates.toString());
}
public LocalCache getLocalCache() {
return localCache;
