AggregateAnalysisEngineController_impl (UIMA-AS: uima-as 2.3.1 API)

java.lang.Object
- org.apache.uima.resource.Resource_ImplBase
- - org.apache.uima.aae.controller.BaseAnalysisEngineController
  - - org.apache.uima.aae.controller.AggregateAnalysisEngineController_impl

All Implemented Interfaces:

Serializable, AggregateAnalysisEngineController, AggregateAnalysisEngineController_implMBean, AnalysisEngineController, BaseAnalysisEngineControllerMBean, ControllerLifecycle, EventSubscriber, org.apache.uima.resource.Resource
```
public class AggregateAnalysisEngineController_impl
extends BaseAnalysisEngineController
implements AggregateAnalysisEngineController, AggregateAnalysisEngineController_implMBean
```
See Also:
Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController
  BaseAnalysisEngineController.ServiceState

Field Summary

Fields
Modifier and Type Field and Description

protected List<AnalysisEngineController> childControllerList

protected boolean initialized

Object parallelStepMux
- Fields inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController
  abortedCasesMap, aeDescriptor, allDelegatesAreRemote, awaitingCacheCallbackNotification, callbackMonitor, callbackReceived, clientEndpoint, cmOutstandingCASes, componentCasPoolSize, controllerListeners, currentState, deadClientDestinationMap, delegateKey, delegates, errorCount, errorHandlerChain, finalStepMux, idleTime, inputChannel, inputChannelList, inputChannelMap, jmxContext, latch, localCache, messageListeners, monitor, NO_RECOVERY, paramsMap, parentController, perCasStatistics, processPid, replyTime, resourceSpecifier, serviceErrorMap, serviceErrors, serviceInitialized, servicePerformance, statsMap, stopped, syncObject, transports, unregisteredDelegateList
- Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController
  AEInstanceCount, CasPoolSize
- Fields inherited from interface org.apache.uima.resource.Resource
  PARAM_AGGREGATE_SOFA_MAPPINGS, PARAM_CONFIG_MANAGER, PARAM_CONFIG_PARAM_SETTINGS, PARAM_EXTERNAL_OVERRIDE_SETTINGS, PARAM_PERFORMANCE_TUNING_SETTINGS, PARAM_RESOURCE_MANAGER, PARAM_UIMA_CONTEXT

Fields
Modifier and Type	Field and Description
`protected List<AnalysisEngineController>`	`childControllerList`
`protected boolean`	`initialized`
`Object`	`parallelStepMux`

Constructor Summary

Constructors
Constructor and Description
`AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, String anEndpointName, String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, Map aDestinationMap)`
`AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, String anEndpointName, String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, Map aDestinationMap, JmxManagement aJmxManagement)`
`AggregateAnalysisEngineController_impl(String anEndpointName, String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, Map aDestinationMap)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addMessageOrigin(String aCasReferenceId, Endpoint anEndpoint)`
`void`	`changeCollocatedDelegateState(String delegateKey, BaseAnalysisEngineController.ServiceState state)`
`void`	`cleanUp()`
`void`	`collectionProcessComplete(Endpoint anEndpoint)`
`boolean`	`continueOnError(String aCasReferenceId, String aDelegateKey, Exception anException)`
`boolean`	`delayCasIfDelegateInTimedOutState(String aCasReferenceId, String aDelegateKey)` Checks the state of a delegate to see if it is in TIMEOUT State.
`void`	`disableDelegates(List aDelegateList)`
`protected void`	`disableDelegates(List aDelegateList, String aCasReferenceId)`
`void`	`dispatchMetadataRequest(Endpoint anEndpoint)`
`void`	`dropCAS(String aCasReferenceId, boolean dropCacheEntry)`
`void`	`dropFlow(String aCasReferenceId, boolean abortFlow)`
`void`	`dumpState(StringBuffer buffer, String lbl1)`
`void`	`enableDelegates(List aDelegateList)`
`void`	`finalStep(org.apache.uima.flow.FinalStep aStep, String aCasReferenceId)`
`List`	`getChildControllerList()`
`ControllerLatch`	`getControllerLatch()`
`ServiceErrors`	`getDelegateServiceErrors(String aDelegateKey)`
`PrimitiveServiceInfo`	`getDelegateServiceInfo(String aDelegateKey)`
`ServicePerformance`	`getDelegateServicePerformance(String aDelegateKey)`
`Map`	`getDelegateStats()`
`String`	`getDescriptor()`
`Map`	`getDestinations()`
`String`	`getLastDelegateKeyFromFlow(String anInputCasReferenceId)`
`LocalCache`	`getLocalCache()`
`Endpoint`	`getMessageOrigin(String aCasReferenceId)`
`Monitor`	`getMonitor()`
`String`	`getServiceEndpointName()`
`ServiceErrors`	`getServiceErrors(String aDelegateKey)`
`AggregateServiceInfo`	`getServiceInfo()`
`ServicePerformance`	`getServicePerformance(String aDelegateKey)`
`void`	`handleDelegateLifeCycleEvent(String anEndpoint, int aDelegateCount)`
`void`	`handleInitializationError(Exception ex)`
`void`	`incrementAnalysisTime(long anAnalysisTime)` Accumulate analysis time for the aggregate
`void`	`initialize()`
`boolean`	`isDelegateDisabled(String aDelegateKey)`
`boolean`	`isDelegateKeyValid(String aDelegateKey)`
`boolean`	`isPrimitive()`
`Delegate`	`lookupDelegate(String aDelegateKey)` Return `Delegate` object for a given delegate key.
`String`	`lookUpDelegateKey(String anEndpointName)`
`String`	`lookUpDelegateKey(String anEndpointName, String server)` Returns a delegate key given an endpoint (queue) name and a server uri.
`Endpoint`	`lookUpEndpoint(String anAnalysisEngineKey, boolean clone)`
`void`	`mapEndpointsToKeys(ConcurrentHashMap aDestinationMap)`
`void`	`mergeTypeSystem(String aTypeSystem, String fromDestination)`
`void`	`mergeTypeSystem(String aTypeSystem, String fromDestination, String fromServer)`
`void`	`onInitialize()` Force all collocated delegates to perform any post-initialization steps.
`void`	`process(org.apache.uima.cas.CAS aCAS, String aCasReferenceId)` This is a process method that is executed for CASes not created by a Multiplier in this aggregate.
`void`	`process(org.apache.uima.cas.CAS aCAS, String anInputCasReferenceId, String aNewCasReferenceId, String newCASProducedBy)` This routine is called to handle CASes produced by a CAS Multiplier.
`void`	`processCollectionCompleteReplyFromDelegate(String aDelegateKey, boolean sendReply)`
`void`	`registerChildController(AnalysisEngineController aChildController, String aDelegateKey)`
`boolean`	`releaseParentCas(boolean casDropped, boolean clientIsCollocated, LocalCache.CasStateEntry parentCasStateEntry)`
`void`	`removeMessageOrigin(String aCasReferenceId)`
`boolean`	`requestForMetaSentToRemotes()`
`void`	`retryLastCommand(int aCommand, Endpoint anEndpoint, String aCasReferenceId)`
`void`	`retryMetadataRequest(Endpoint anEndpoint)`
`void`	`retryProcessCASRequest(String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache)`
`void`	`saveStatsFromService(String aServiceEndpointName, Map aServiceStats)`
`void`	`sendMetadata(Endpoint anEndpoint)`
`void`	`sendRequestForMetadataToRemoteDelegates()`
`void`	`setCasLoggingDirectory(String key, String directory)`
`void`	`setControllerBeanName(String aBeanName)`
`void`	`setDescriptor(String descriptor)`
`void`	`setFlowControllerDescriptor(String aFlowControllerDescriptor)`
`void`	`setMonitor(Monitor monitor)`
`void`	`setRequestForMetaSentToRemotes()`
`void`	`setServiceEndpointName(String anEndpointName)`
`void`	`stop()` Stops input channel(s) and initiates a shutdown of all delegates ( if this is an aggregate ).
`void`	`stopTimers()`
`void`	`takeAction(String anAction, String anEndpointName, ErrorContext anErrorContext)`

Methods inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController
abortGeneratingCASes, addAbortedCasReferenceId, addControllerCallbackListener, addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, clearStats, dropCAS, dropCasStatistics, dropStats, endProcess, exceedsThresholdWithinWindow, forceTimeoutOnPendingCases, getAnalysisTime, getBrokerURL, getCasManagerWrapper, getCasMultiplierController, getCasStatistics, getChildUimaContext, getClientEndpoint, getComponentName, getCpuTime, getDeadClientMap, getDeploymentDescriptor, getDeploymentMode, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getInputQueue, getJmxContext, getJMXDomain, getKey, getManagementInterface, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getResourceSpecifier, getServiceErrors, getServiceName, getServicePerformance, getState, getStats, getTime, getTotalNumberOfCASesDropped, getTotalNumberOfCASesProcessed, getTotalNumberOfCASesReceived, getTotalNumberOfErrors, getTotalTimeSpendDeSerializingCAS, getTotalTimeSpentSerializingCAS, getTotalTimeSpentWaitingForFreeCASInstance, getTransport, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, handleAction, handleError, incrementDeserializationTime, incrementErrorCounter, incrementSerializationTime, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isStopped, isTopLevelComponent, logStats, logStats, notifyListenersWithInitializationStatus, onCacheEmpty, plugInDefaultErrorHandlerChain, process, quiesceAndStop, registerServiceWithJMX, registerVmQueueWithJMX, registerWithAgent, releaseNextCas, removeControllerCallbackListener, resetErrorCounter, saveReplyTime, saveTime, sendMetadata, setCasManager, setDeployDescriptor, setErrorHandlerChain, setInputChannel, setJmxManagement, setOutputChannel, setStopped, setUimaEEAdminContext, stop, stopCasMultiplier, stopCasMultipliers, stopDelegateTimers, stopInputChannel, stopInputChannels, stopTransportLayer, terminate, terminate, toString

Methods inherited from class org.apache.uima.resource.Resource_ImplBase
destroy, getCasManager, getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, initialize, setLogger, setMetaData

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.uima.aae.controller.AggregateAnalysisEngineController
getChildUimaContext, stopCasMultiplier

Methods inherited from interface org.apache.uima.aae.controller.AnalysisEngineController
addAbortedCasReferenceId, addInputChannel, addServiceInfo, beginProcess, cacheClientEndpoint, changeState, dropCAS, dropStats, endProcess, forceTimeoutOnPendingCases, getAnalysisTime, getCasManagerWrapper, getCasStatistics, getClientEndpoint, getComponentName, getCpuTime, getDeadClientMap, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getJmxContext, getJMXDomain, getKey, getManagementInterface, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getServiceErrors, getServicePerformance, getState, getStats, getTime, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, incrementDeserializationTime, incrementSerializationTime, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isStopped, isTopLevelComponent, notifyListenersWithInitializationStatus, process, quiesceAndStop, registerVmQueueWithJMX, releaseNextCas, saveReplyTime, saveTime, setCasManager, setDeployDescriptor, setInputChannel, setOutputChannel, setStopped, setUimaEEAdminContext

Methods inherited from interface org.apache.uima.aae.controller.ControllerLifecycle
addControllerCallbackListener, removeControllerCallbackListener, terminate

Methods inherited from interface org.apache.uima.aae.controller.BaseAnalysisEngineControllerMBean
getBrokerURL, getComponentName, getDeploymentDescriptor, getDeploymentMode, getIdleTime, getInputQueue, getServiceName, getTotalNumberOfCASesDropped, getTotalNumberOfCASesProcessed, getTotalNumberOfCASesReceived, getTotalNumberOfErrors, getTotalTimeSpendDeSerializingCAS, getTotalTimeSpentSerializingCAS, getTotalTimeSpentWaitingForFreeCASInstance

Field Detail

initialized
```
protected volatile boolean initialized
```

childControllerList

protected List<AnalysisEngineController> childControllerList

parallelStepMux
```
public final Object parallelStepMux
```

Constructor Detail

AggregateAnalysisEngineController_impl

public AggregateAnalysisEngineController_impl(String anEndpointName,
                                      String aDescriptor,
                                      AsynchAECasManager aCasManager,
                                      InProcessCache anInProcessCache,
                                      Map aDestinationMap)
                                       throws Exception

Parameters:: anEndpointName -; aDescriptor -; aCasManager -; anInProcessCache -; aDestinationMap -
Throws:: Exception

AggregateAnalysisEngineController_impl

public AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController,
                                      String anEndpointName,
                                      String aDescriptor,
                                      AsynchAECasManager aCasManager,
                                      InProcessCache anInProcessCache,
                                      Map aDestinationMap)
                                       throws Exception

Parameters:: aParentController -; anEndpointName -; aDescriptor -; aCasManager -; anInProcessCache -; aDestinationMap -
Throws:: Exception

AggregateAnalysisEngineController_impl

public AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController,
                                      String anEndpointName,
                                      String aDescriptor,
                                      AsynchAECasManager aCasManager,
                                      InProcessCache anInProcessCache,
                                      Map aDestinationMap,
                                      JmxManagement aJmxManagement)
                                       throws Exception

Throws:: Exception

Method Detail
- registerChildController
```
public void registerChildController(AnalysisEngineController aChildController,
                           String aDelegateKey)
                             throws Exception
```
  Specified by:
  
  registerChildController in interface AggregateAnalysisEngineController
  
  Throws:
  
  Exception
- saveStatsFromService
```
public void saveStatsFromService(String aServiceEndpointName,
                        Map aServiceStats)
```
  Specified by:
  
  saveStatsFromService in interface AggregateAnalysisEngineController
- addMessageOrigin
```
public void addMessageOrigin(String aCasReferenceId,
                    Endpoint anEndpoint)
```
  Specified by:
  
  addMessageOrigin in interface AggregateAnalysisEngineController
- isDelegateDisabled
```
public boolean isDelegateDisabled(String aDelegateKey)
```
  Specified by:
  
  isDelegateDisabled in interface AggregateAnalysisEngineController
- setServiceEndpointName
```
public void setServiceEndpointName(String anEndpointName)
```
  Parameters:
  anEndpointName -
- getServiceEndpointName
```
public String getServiceEndpointName()
```
  Specified by:
  
  getServiceEndpointName in interface AnalysisEngineController
- setControllerBeanName
```
public void setControllerBeanName(String aBeanName)
```
  Parameters:
  aBeanName -
- getMessageOrigin
```
public Endpoint getMessageOrigin(String aCasReferenceId)
```
  Specified by:
  
  getMessageOrigin in interface AggregateAnalysisEngineController
- removeMessageOrigin
```
public void removeMessageOrigin(String aCasReferenceId)
```
  Specified by:
  
  removeMessageOrigin in interface AggregateAnalysisEngineController
- dropCAS
```
public void dropCAS(String aCasReferenceId,
           boolean dropCacheEntry)
```
  Specified by:
  
  dropCAS in interface AnalysisEngineController
  
  Overrides:
  
  dropCAS in class BaseAnalysisEngineController
- dropFlow
```
public void dropFlow(String aCasReferenceId,
            boolean abortFlow)
```
  Specified by:
  
  dropFlow in interface AggregateAnalysisEngineController
- mapEndpointsToKeys
```
public void mapEndpointsToKeys(ConcurrentHashMap aDestinationMap)
```
  Specified by:
  
  mapEndpointsToKeys in interface AggregateAnalysisEngineController
- getDelegateStats
```
public Map getDelegateStats()
```
  Specified by:
  
  getDelegateStats in interface AggregateAnalysisEngineController
- processCollectionCompleteReplyFromDelegate
```
public void processCollectionCompleteReplyFromDelegate(String aDelegateKey,
                                              boolean sendReply)
                                                throws AsynchAEException
```
  Specified by:
  
  processCollectionCompleteReplyFromDelegate in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- setFlowControllerDescriptor
```
public void setFlowControllerDescriptor(String aFlowControllerDescriptor)
```
  Parameters:
  aFlowControllerDescriptor -
- takeAction
```
public void takeAction(String anAction,
              String anEndpointName,
              ErrorContext anErrorContext)
```
  Specified by:
  
  takeAction in interface AnalysisEngineController
- collectionProcessComplete
```
public void collectionProcessComplete(Endpoint anEndpoint)
                               throws AsynchAEException
```
  Specified by:
  
  collectionProcessComplete in interface AnalysisEngineController
  
  Throws:
  
  AsynchAEException
- getDescriptor
```
public String getDescriptor()
```
- setDescriptor
```
public void setDescriptor(String descriptor)
```
- isPrimitive
```
public boolean isPrimitive()
```
  Specified by:
  
  isPrimitive in interface AnalysisEngineController
- getDestinations
```
public Map getDestinations()
```
  Specified by:
  
  getDestinations in interface AggregateAnalysisEngineController
- enableDelegates
```
public void enableDelegates(List aDelegateList)
                     throws AsynchAEException
```
  Specified by:
  
  enableDelegates in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- handleInitializationError
```
public void handleInitializationError(Exception ex)
```
- disableDelegates
```
public void disableDelegates(List aDelegateList)
                      throws AsynchAEException
```
  Specified by:
  
  disableDelegates in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- disableDelegates
```
protected void disableDelegates(List aDelegateList,
                    String aCasReferenceId)
                         throws AsynchAEException
```
  Throws:
  
  AsynchAEException
- continueOnError
```
public boolean continueOnError(String aCasReferenceId,
                      String aDelegateKey,
                      Exception anException)
                        throws AsynchAEException
```
  Specified by:
  
  continueOnError in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- getLastDelegateKeyFromFlow
```
public String getLastDelegateKeyFromFlow(String anInputCasReferenceId)
```
  Specified by:
  
  getLastDelegateKeyFromFlow in interface AggregateAnalysisEngineController
- process
```
public void process(org.apache.uima.cas.CAS aCAS,
           String anInputCasReferenceId,
           String aNewCasReferenceId,
           String newCASProducedBy)
```
  This routine is called to handle CASes produced by a CAS Multiplier. A new CAS needs a flow object which is produced here from the Flow associated with the input CAS. Once the subflow is computed, it is cached for future use.
  
  Specified by:
  
  process in interface AnalysisEngineController
  
  Overrides:
  
  process in class BaseAnalysisEngineController
  
  Parameters:
  aCAS - - CAS to process
  anInputCasReferenceId - - reference id of the input CAS
  aNewCasReferenceId - - reference id of the CAS created by the CAS multiplier
  newCASProducedBy - - name of the multiplier that created the CAS
  
  Throws:
  
  org.apache.uima.analysis_engine.AnalysisEngineProcessException
  
  AsynchAEException
- process
```
public void process(org.apache.uima.cas.CAS aCAS,
           String aCasReferenceId)
```
  This is a process method that is executed for CASes not created by a Multiplier in this aggregate.
  
  Specified by:
  
  process in interface AnalysisEngineController
  
  Overrides:
  
  process in class BaseAnalysisEngineController
- sendRequestForMetadataToRemoteDelegates
```
public void sendRequestForMetadataToRemoteDelegates()
                                             throws AsynchAEException
```
  Specified by:
  
  sendRequestForMetadataToRemoteDelegates in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- finalStep
```
public void finalStep(org.apache.uima.flow.FinalStep aStep,
             String aCasReferenceId)
```
  Specified by:
  
  finalStep in interface AggregateAnalysisEngineController
- releaseParentCas
```
public boolean releaseParentCas(boolean casDropped,
                       boolean clientIsCollocated,
                       LocalCache.CasStateEntry parentCasStateEntry)
```
- delayCasIfDelegateInTimedOutState
```
public boolean delayCasIfDelegateInTimedOutState(String aCasReferenceId,
                                        String aDelegateKey)
                                          throws AsynchAEException
```
  Checks the state of a delegate to see if it is in TIMEOUT State. If it is, push the CAS id onto a list of CASes pending dispatch. The delegate is in a questionable state and the aggregate sends a ping message to check delegate's availability. If the delegate responds to the ping, all CASes in the pending dispatch list will be immediately dispatched.
  
  Specified by:
  
  delayCasIfDelegateInTimedOutState in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- retryProcessCASRequest
```
public void retryProcessCASRequest(String aCasReferenceId,
                          Endpoint anEndpoint,
                          boolean addEndpointToCache)
                            throws AsynchAEException
```
  Specified by:
  
  retryProcessCASRequest in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- isDelegateKeyValid
```
public boolean isDelegateKeyValid(String aDelegateKey)
```
  Specified by:
  
  isDelegateKeyValid in interface AggregateAnalysisEngineController
- lookUpDelegateKey
```
public String lookUpDelegateKey(String anEndpointName)
```
  Specified by:
  
  lookUpDelegateKey in interface AggregateAnalysisEngineController
- lookUpDelegateKey
```
public String lookUpDelegateKey(String anEndpointName,
                       String server)
```
  Returns a delegate key given an endpoint (queue) name and a server uri. If a server is null, only the endpoint name will be used for matching.
  
  Specified by:
  
  lookUpDelegateKey in interface AggregateAnalysisEngineController
- lookUpEndpoint
```
public Endpoint lookUpEndpoint(String anAnalysisEngineKey,
                      boolean clone)
                        throws AsynchAEException
```
  Specified by:
  
  lookUpEndpoint in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- getDelegateServiceInfo
```
public PrimitiveServiceInfo getDelegateServiceInfo(String aDelegateKey)
```
  Specified by:
  
  getDelegateServiceInfo in interface AggregateAnalysisEngineController
- getDelegateServicePerformance
```
public ServicePerformance getDelegateServicePerformance(String aDelegateKey)
```
  Specified by:
  
  getDelegateServicePerformance in interface AggregateAnalysisEngineController
- getDelegateServiceErrors
```
public ServiceErrors getDelegateServiceErrors(String aDelegateKey)
```
  Specified by:
  
  getDelegateServiceErrors in interface AggregateAnalysisEngineController
- mergeTypeSystem
```
public void mergeTypeSystem(String aTypeSystem,
                   String fromDestination)
                     throws AsynchAEException
```
  Specified by:
  
  mergeTypeSystem in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- mergeTypeSystem
```
public void mergeTypeSystem(String aTypeSystem,
                   String fromDestination,
                   String fromServer)
                     throws AsynchAEException
```
  Specified by:
  
  mergeTypeSystem in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- initialize
```
public void initialize()
                throws AsynchAEException
```
  Specified by:
  
  initialize in interface AnalysisEngineController
  
  Throws:
  
  AsynchAEException
- dispatchMetadataRequest
```
public void dispatchMetadataRequest(Endpoint anEndpoint)
                             throws AsynchAEException
```
  Specified by:
  
  dispatchMetadataRequest in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- retryMetadataRequest
```
public void retryMetadataRequest(Endpoint anEndpoint)
                          throws AsynchAEException
```
  Specified by:
  
  retryMetadataRequest in interface AggregateAnalysisEngineController
  
  Throws:
  
  AsynchAEException
- sendMetadata
```
public void sendMetadata(Endpoint anEndpoint)
```
  Specified by:
  
  sendMetadata in interface AnalysisEngineController
- getControllerLatch
```
public ControllerLatch getControllerLatch()
```
  Specified by:
  
  getControllerLatch in interface AnalysisEngineController
- getMonitor
```
public Monitor getMonitor()
```
  Specified by:
  
  getMonitor in interface AnalysisEngineController
- setMonitor
```
public void setMonitor(Monitor monitor)
```
- handleDelegateLifeCycleEvent
```
public void handleDelegateLifeCycleEvent(String anEndpoint,
                                int aDelegateCount)
```
  Specified by:
  
  handleDelegateLifeCycleEvent in interface AnalysisEngineController
- retryLastCommand
```
public void retryLastCommand(int aCommand,
                    Endpoint anEndpoint,
                    String aCasReferenceId)
```
  Specified by:
  
  retryLastCommand in interface AggregateAnalysisEngineController
- getServiceErrors
```
public ServiceErrors getServiceErrors(String aDelegateKey)
```
- getServiceInfo
```
public AggregateServiceInfo getServiceInfo()
```
  Specified by:
  
  getServiceInfo in interface AggregateAnalysisEngineController
  
  Specified by:
  
  getServiceInfo in interface AnalysisEngineController
- getServicePerformance
```
public ServicePerformance getServicePerformance(String aDelegateKey)
```
  Specified by:
  
  getServicePerformance in interface AggregateAnalysisEngineController
- incrementAnalysisTime
```
public void incrementAnalysisTime(long anAnalysisTime)
```
  Accumulate analysis time for the aggregate
  
  Parameters:
  anAnalysisTime -
- stopTimers
```
public void stopTimers()
```
  Specified by:
  
  stopTimers in interface AggregateAnalysisEngineController
- requestForMetaSentToRemotes
```
public boolean requestForMetaSentToRemotes()
```
  Specified by:
  
  requestForMetaSentToRemotes in interface AggregateAnalysisEngineController
- setRequestForMetaSentToRemotes
```
public void setRequestForMetaSentToRemotes()
```
  Specified by:
  
  setRequestForMetaSentToRemotes in interface AggregateAnalysisEngineController
- cleanUp
```
public void cleanUp()
```
  Overrides:
  
  cleanUp in class BaseAnalysisEngineController
- stop
```
public void stop()
```
  Description copied from class: BaseAnalysisEngineController
  
  Stops input channel(s) and initiates a shutdown of all delegates ( if this is an aggregate ). At the end sends an Exception to the client and closes an output channel.
  
  Specified by:
  
  stop in interface AnalysisEngineController
  
  Overrides:
  
  stop in class BaseAnalysisEngineController
- getChildControllerList
```
public List getChildControllerList()
```
  Specified by:
  
  getChildControllerList in interface AggregateAnalysisEngineController
- onInitialize
```
public void onInitialize()
```
  Force all collocated delegates to perform any post-initialization steps.
  
  Specified by:
  
  onInitialize in interface AnalysisEngineController
- changeCollocatedDelegateState
```
public void changeCollocatedDelegateState(String delegateKey,
                                 BaseAnalysisEngineController.ServiceState state)
                                   throws Exception
```
  Specified by:
  
  changeCollocatedDelegateState in interface AggregateAnalysisEngineController
  
  Throws:
  
  Exception
- dumpState
```
public void dumpState(StringBuffer buffer,
             String lbl1)
```
  Specified by:
  
  dumpState in interface AnalysisEngineController
  
  Specified by:
  
  dumpState in class BaseAnalysisEngineController
- getLocalCache
```
public LocalCache getLocalCache()
```
  Specified by:
  
  getLocalCache in interface AnalysisEngineController
  
  Overrides:
  
  getLocalCache in class BaseAnalysisEngineController
- lookupDelegate
```
public Delegate lookupDelegate(String aDelegateKey)
```
  Return Delegate object for a given delegate key.
  
  Specified by:
  
  lookupDelegate in interface AggregateAnalysisEngineController
- setCasLoggingDirectory
```
public void setCasLoggingDirectory(String key,
                          String directory)
```
  Specified by:
  
  setCasLoggingDirectory in interface AggregateAnalysisEngineController

Class AggregateAnalysisEngineController_impl

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController

Field Summary

Fields inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController

Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController

Fields inherited from interface org.apache.uima.resource.Resource

Constructor Summary

Method Summary

Methods inherited from class org.apache.uima.aae.controller.BaseAnalysisEngineController

Methods inherited from class org.apache.uima.resource.Resource_ImplBase

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.uima.aae.controller.AggregateAnalysisEngineController

Methods inherited from interface org.apache.uima.aae.controller.AnalysisEngineController

Methods inherited from interface org.apache.uima.aae.controller.ControllerLifecycle

Methods inherited from interface org.apache.uima.aae.controller.BaseAnalysisEngineControllerMBean

Field Detail

initialized

childControllerList

parallelStepMux

Constructor Detail

AggregateAnalysisEngineController_impl

AggregateAnalysisEngineController_impl

AggregateAnalysisEngineController_impl

Method Detail

registerChildController

saveStatsFromService

addMessageOrigin

isDelegateDisabled

setServiceEndpointName

getServiceEndpointName

setControllerBeanName

getMessageOrigin

removeMessageOrigin

dropCAS

dropFlow

mapEndpointsToKeys

getDelegateStats

processCollectionCompleteReplyFromDelegate

setFlowControllerDescriptor

takeAction

collectionProcessComplete

getDescriptor

setDescriptor

isPrimitive

getDestinations

enableDelegates

handleInitializationError

disableDelegates

disableDelegates

continueOnError

getLastDelegateKeyFromFlow

process

process

sendRequestForMetadataToRemoteDelegates

finalStep

releaseParentCas

delayCasIfDelegateInTimedOutState

retryProcessCASRequest

isDelegateKeyValid

lookUpDelegateKey

lookUpDelegateKey

lookUpEndpoint

getDelegateServiceInfo

getDelegateServicePerformance

getDelegateServiceErrors

mergeTypeSystem

mergeTypeSystem

initialize

dispatchMetadataRequest

retryMetadataRequest

sendMetadata

getControllerLatch

getMonitor

setMonitor

handleDelegateLifeCycleEvent

retryLastCommand

getServiceErrors

getServiceInfo

getServicePerformance