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

Description

protected List<AnalysisEngineController>

childControllerList

protected boolean

initialized

final 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
Constructor Summary

Constructors

Constructor

Description

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

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)
Method Summary

Modifier and Type

Method

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, getRelativePathResolver, 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.BaseAnalysisEngineControllerMBean
getBrokerURL, getComponentName, getDeploymentDescriptor, getDeploymentMode, getIdleTime, getInputQueue, getServiceName, getTotalNumberOfCASesDropped, getTotalNumberOfCASesProcessed, getTotalNumberOfCASesReceived, getTotalNumberOfErrors, getTotalTimeSpendDeSerializingCAS, getTotalTimeSpentSerializingCAS, getTotalTimeSpentWaitingForFreeCASInstance

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

Field Details
- initialized
  
  protected volatile boolean initialized
- childControllerList
  
  protected List<AnalysisEngineController> childControllerList
- parallelStepMux
  
  public final Object parallelStepMux
Constructor Details
- 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 Details
- 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.BaseAnalysisEngineControllerMBean

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

Field Details

initialized

childControllerList

parallelStepMux

Constructor Details

AggregateAnalysisEngineController_impl

AggregateAnalysisEngineController_impl

AggregateAnalysisEngineController_impl

Method Details

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