org.apache.uima.aae.controller

Class AggregateAnalysisEngineController_impl

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

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

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