Package 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:
java.io.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 java.util.List<AnalysisEngineController>
childControllerList
protected boolean
initialized
java.lang.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
-
-
Constructor Summary
Constructors Constructor Description AggregateAnalysisEngineController_impl(java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap)
AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap)
AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap, JmxManagement aJmxManagement)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addMessageOrigin(java.lang.String aCasReferenceId, Endpoint anEndpoint)
void
changeCollocatedDelegateState(java.lang.String delegateKey, BaseAnalysisEngineController.ServiceState state)
void
cleanUp()
void
collectionProcessComplete(Endpoint anEndpoint)
boolean
continueOnError(java.lang.String aCasReferenceId, java.lang.String aDelegateKey, java.lang.Exception anException)
boolean
delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId, java.lang.String aDelegateKey)
Checks the state of a delegate to see if it is in TIMEOUT State.void
disableDelegates(java.util.List aDelegateList)
protected void
disableDelegates(java.util.List aDelegateList, java.lang.String aCasReferenceId)
void
dispatchMetadataRequest(Endpoint anEndpoint)
void
dropCAS(java.lang.String aCasReferenceId, boolean dropCacheEntry)
void
dropFlow(java.lang.String aCasReferenceId, boolean abortFlow)
void
dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
void
enableDelegates(java.util.List aDelegateList)
void
finalStep(org.apache.uima.flow.FinalStep aStep, java.lang.String aCasReferenceId)
java.util.List
getChildControllerList()
ControllerLatch
getControllerLatch()
ServiceErrors
getDelegateServiceErrors(java.lang.String aDelegateKey)
PrimitiveServiceInfo
getDelegateServiceInfo(java.lang.String aDelegateKey)
ServicePerformance
getDelegateServicePerformance(java.lang.String aDelegateKey)
java.util.Map
getDelegateStats()
java.lang.String
getDescriptor()
java.util.Map
getDestinations()
java.lang.String
getLastDelegateKeyFromFlow(java.lang.String anInputCasReferenceId)
LocalCache
getLocalCache()
Endpoint
getMessageOrigin(java.lang.String aCasReferenceId)
Monitor
getMonitor()
java.lang.String
getServiceEndpointName()
ServiceErrors
getServiceErrors(java.lang.String aDelegateKey)
AggregateServiceInfo
getServiceInfo()
ServicePerformance
getServicePerformance(java.lang.String aDelegateKey)
void
handleDelegateLifeCycleEvent(java.lang.String anEndpoint, int aDelegateCount)
void
handleInitializationError(java.lang.Exception ex)
void
incrementAnalysisTime(long anAnalysisTime)
Accumulate analysis time for the aggregatevoid
initialize()
boolean
isDelegateDisabled(java.lang.String aDelegateKey)
boolean
isDelegateKeyValid(java.lang.String aDelegateKey)
boolean
isPrimitive()
Delegate
lookupDelegate(java.lang.String aDelegateKey)
ReturnDelegate
object for a given delegate key.java.lang.String
lookUpDelegateKey(java.lang.String anEndpointName)
java.lang.String
lookUpDelegateKey(java.lang.String anEndpointName, java.lang.String server)
Returns a delegate key given an endpoint (queue) name and a server uri.Endpoint
lookUpEndpoint(java.lang.String anAnalysisEngineKey, boolean clone)
void
mapEndpointsToKeys(java.util.concurrent.ConcurrentHashMap aDestinationMap)
void
mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination)
void
mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination, java.lang.String fromServer)
void
onInitialize()
Force all collocated delegates to perform any post-initialization steps.void
process(org.apache.uima.cas.CAS aCAS, java.lang.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, java.lang.String anInputCasReferenceId, java.lang.String aNewCasReferenceId, java.lang.String newCASProducedBy)
This routine is called to handle CASes produced by a CAS Multiplier.void
processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey, boolean sendReply)
void
registerChildController(AnalysisEngineController aChildController, java.lang.String aDelegateKey)
boolean
releaseParentCas(boolean casDropped, boolean clientIsCollocated, LocalCache.CasStateEntry parentCasStateEntry)
void
removeMessageOrigin(java.lang.String aCasReferenceId)
boolean
requestForMetaSentToRemotes()
void
retryLastCommand(int aCommand, Endpoint anEndpoint, java.lang.String aCasReferenceId)
void
retryMetadataRequest(Endpoint anEndpoint)
void
retryProcessCASRequest(java.lang.String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache)
void
saveStatsFromService(java.lang.String aServiceEndpointName, java.util.Map aServiceStats)
void
sendMetadata(Endpoint anEndpoint)
void
sendRequestForMetadataToRemoteDelegates()
void
setCasLoggingDirectory(java.lang.String key, java.lang.String directory)
void
setControllerBeanName(java.lang.String aBeanName)
void
setDescriptor(java.lang.String descriptor)
void
setFlowControllerDescriptor(java.lang.String aFlowControllerDescriptor)
void
setMonitor(Monitor monitor)
void
setRequestForMetaSentToRemotes()
void
setServiceEndpointName(java.lang.String anEndpointName)
void
stop()
Stops input channel(s) and initiates a shutdown of all delegates ( if this is an aggregate ).void
stopTimers()
void
takeAction(java.lang.String anAction, java.lang.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 Detail
-
initialized
protected volatile boolean initialized
-
childControllerList
protected java.util.List<AnalysisEngineController> childControllerList
-
parallelStepMux
public final java.lang.Object parallelStepMux
-
-
Constructor Detail
-
AggregateAnalysisEngineController_impl
public AggregateAnalysisEngineController_impl(java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap) throws java.lang.Exception
- Parameters:
anEndpointName
-aDescriptor
-aCasManager
-anInProcessCache
-aDestinationMap
-- Throws:
java.lang.Exception
-
AggregateAnalysisEngineController_impl
public AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap) throws java.lang.Exception
- Parameters:
aParentController
-anEndpointName
-aDescriptor
-aCasManager
-anInProcessCache
-aDestinationMap
-- Throws:
java.lang.Exception
-
AggregateAnalysisEngineController_impl
public AggregateAnalysisEngineController_impl(AnalysisEngineController aParentController, java.lang.String anEndpointName, java.lang.String aDescriptor, AsynchAECasManager aCasManager, InProcessCache anInProcessCache, java.util.Map aDestinationMap, JmxManagement aJmxManagement) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-
Method Detail
-
registerChildController
public void registerChildController(AnalysisEngineController aChildController, java.lang.String aDelegateKey) throws java.lang.Exception
- Specified by:
registerChildController
in interfaceAggregateAnalysisEngineController
- Throws:
java.lang.Exception
-
saveStatsFromService
public void saveStatsFromService(java.lang.String aServiceEndpointName, java.util.Map aServiceStats)
- Specified by:
saveStatsFromService
in interfaceAggregateAnalysisEngineController
-
addMessageOrigin
public void addMessageOrigin(java.lang.String aCasReferenceId, Endpoint anEndpoint)
- Specified by:
addMessageOrigin
in interfaceAggregateAnalysisEngineController
-
isDelegateDisabled
public boolean isDelegateDisabled(java.lang.String aDelegateKey)
- Specified by:
isDelegateDisabled
in interfaceAggregateAnalysisEngineController
-
setServiceEndpointName
public void setServiceEndpointName(java.lang.String anEndpointName)
- Parameters:
anEndpointName
-
-
getServiceEndpointName
public java.lang.String getServiceEndpointName()
- Specified by:
getServiceEndpointName
in interfaceAnalysisEngineController
-
setControllerBeanName
public void setControllerBeanName(java.lang.String aBeanName)
- Parameters:
aBeanName
-
-
getMessageOrigin
public Endpoint getMessageOrigin(java.lang.String aCasReferenceId)
- Specified by:
getMessageOrigin
in interfaceAggregateAnalysisEngineController
-
removeMessageOrigin
public void removeMessageOrigin(java.lang.String aCasReferenceId)
- Specified by:
removeMessageOrigin
in interfaceAggregateAnalysisEngineController
-
dropCAS
public void dropCAS(java.lang.String aCasReferenceId, boolean dropCacheEntry)
- Specified by:
dropCAS
in interfaceAnalysisEngineController
- Overrides:
dropCAS
in classBaseAnalysisEngineController
-
dropFlow
public void dropFlow(java.lang.String aCasReferenceId, boolean abortFlow)
- Specified by:
dropFlow
in interfaceAggregateAnalysisEngineController
-
mapEndpointsToKeys
public void mapEndpointsToKeys(java.util.concurrent.ConcurrentHashMap aDestinationMap)
- Specified by:
mapEndpointsToKeys
in interfaceAggregateAnalysisEngineController
-
getDelegateStats
public java.util.Map getDelegateStats()
- Specified by:
getDelegateStats
in interfaceAggregateAnalysisEngineController
-
processCollectionCompleteReplyFromDelegate
public void processCollectionCompleteReplyFromDelegate(java.lang.String aDelegateKey, boolean sendReply) throws AsynchAEException
- Specified by:
processCollectionCompleteReplyFromDelegate
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
setFlowControllerDescriptor
public void setFlowControllerDescriptor(java.lang.String aFlowControllerDescriptor)
- Parameters:
aFlowControllerDescriptor
-
-
takeAction
public void takeAction(java.lang.String anAction, java.lang.String anEndpointName, ErrorContext anErrorContext)
- Specified by:
takeAction
in interfaceAnalysisEngineController
-
collectionProcessComplete
public void collectionProcessComplete(Endpoint anEndpoint) throws AsynchAEException
- Specified by:
collectionProcessComplete
in interfaceAnalysisEngineController
- Throws:
AsynchAEException
-
getDescriptor
public java.lang.String getDescriptor()
-
setDescriptor
public void setDescriptor(java.lang.String descriptor)
-
isPrimitive
public boolean isPrimitive()
- Specified by:
isPrimitive
in interfaceAnalysisEngineController
-
getDestinations
public java.util.Map getDestinations()
- Specified by:
getDestinations
in interfaceAggregateAnalysisEngineController
-
enableDelegates
public void enableDelegates(java.util.List aDelegateList) throws AsynchAEException
- Specified by:
enableDelegates
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
handleInitializationError
public void handleInitializationError(java.lang.Exception ex)
-
disableDelegates
public void disableDelegates(java.util.List aDelegateList) throws AsynchAEException
- Specified by:
disableDelegates
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
disableDelegates
protected void disableDelegates(java.util.List aDelegateList, java.lang.String aCasReferenceId) throws AsynchAEException
- Throws:
AsynchAEException
-
continueOnError
public boolean continueOnError(java.lang.String aCasReferenceId, java.lang.String aDelegateKey, java.lang.Exception anException) throws AsynchAEException
- Specified by:
continueOnError
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
getLastDelegateKeyFromFlow
public java.lang.String getLastDelegateKeyFromFlow(java.lang.String anInputCasReferenceId)
- Specified by:
getLastDelegateKeyFromFlow
in interfaceAggregateAnalysisEngineController
-
process
public void process(org.apache.uima.cas.CAS aCAS, java.lang.String anInputCasReferenceId, java.lang.String aNewCasReferenceId, java.lang.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 interfaceAnalysisEngineController
- Overrides:
process
in classBaseAnalysisEngineController
- Parameters:
aCAS
- - CAS to processanInputCasReferenceId
- - reference id of the input CASaNewCasReferenceId
- - reference id of the CAS created by the CAS multipliernewCASProducedBy
- - 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, java.lang.String aCasReferenceId)
This is a process method that is executed for CASes not created by a Multiplier in this aggregate.- Specified by:
process
in interfaceAnalysisEngineController
- Overrides:
process
in classBaseAnalysisEngineController
-
sendRequestForMetadataToRemoteDelegates
public void sendRequestForMetadataToRemoteDelegates() throws AsynchAEException
- Specified by:
sendRequestForMetadataToRemoteDelegates
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
finalStep
public void finalStep(org.apache.uima.flow.FinalStep aStep, java.lang.String aCasReferenceId)
- Specified by:
finalStep
in interfaceAggregateAnalysisEngineController
-
releaseParentCas
public boolean releaseParentCas(boolean casDropped, boolean clientIsCollocated, LocalCache.CasStateEntry parentCasStateEntry)
-
delayCasIfDelegateInTimedOutState
public boolean delayCasIfDelegateInTimedOutState(java.lang.String aCasReferenceId, java.lang.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 interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
retryProcessCASRequest
public void retryProcessCASRequest(java.lang.String aCasReferenceId, Endpoint anEndpoint, boolean addEndpointToCache) throws AsynchAEException
- Specified by:
retryProcessCASRequest
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
isDelegateKeyValid
public boolean isDelegateKeyValid(java.lang.String aDelegateKey)
- Specified by:
isDelegateKeyValid
in interfaceAggregateAnalysisEngineController
-
lookUpDelegateKey
public java.lang.String lookUpDelegateKey(java.lang.String anEndpointName)
- Specified by:
lookUpDelegateKey
in interfaceAggregateAnalysisEngineController
-
lookUpDelegateKey
public java.lang.String lookUpDelegateKey(java.lang.String anEndpointName, java.lang.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 interfaceAggregateAnalysisEngineController
-
lookUpEndpoint
public Endpoint lookUpEndpoint(java.lang.String anAnalysisEngineKey, boolean clone) throws AsynchAEException
- Specified by:
lookUpEndpoint
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
getDelegateServiceInfo
public PrimitiveServiceInfo getDelegateServiceInfo(java.lang.String aDelegateKey)
- Specified by:
getDelegateServiceInfo
in interfaceAggregateAnalysisEngineController
-
getDelegateServicePerformance
public ServicePerformance getDelegateServicePerformance(java.lang.String aDelegateKey)
- Specified by:
getDelegateServicePerformance
in interfaceAggregateAnalysisEngineController
-
getDelegateServiceErrors
public ServiceErrors getDelegateServiceErrors(java.lang.String aDelegateKey)
- Specified by:
getDelegateServiceErrors
in interfaceAggregateAnalysisEngineController
-
mergeTypeSystem
public void mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination) throws AsynchAEException
- Specified by:
mergeTypeSystem
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
mergeTypeSystem
public void mergeTypeSystem(java.lang.String aTypeSystem, java.lang.String fromDestination, java.lang.String fromServer) throws AsynchAEException
- Specified by:
mergeTypeSystem
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
initialize
public void initialize() throws AsynchAEException
- Specified by:
initialize
in interfaceAnalysisEngineController
- Throws:
AsynchAEException
-
dispatchMetadataRequest
public void dispatchMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
- Specified by:
dispatchMetadataRequest
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
retryMetadataRequest
public void retryMetadataRequest(Endpoint anEndpoint) throws AsynchAEException
- Specified by:
retryMetadataRequest
in interfaceAggregateAnalysisEngineController
- Throws:
AsynchAEException
-
sendMetadata
public void sendMetadata(Endpoint anEndpoint)
- Specified by:
sendMetadata
in interfaceAnalysisEngineController
-
getControllerLatch
public ControllerLatch getControllerLatch()
- Specified by:
getControllerLatch
in interfaceAnalysisEngineController
-
getMonitor
public Monitor getMonitor()
- Specified by:
getMonitor
in interfaceAnalysisEngineController
-
setMonitor
public void setMonitor(Monitor monitor)
-
handleDelegateLifeCycleEvent
public void handleDelegateLifeCycleEvent(java.lang.String anEndpoint, int aDelegateCount)
- Specified by:
handleDelegateLifeCycleEvent
in interfaceAnalysisEngineController
-
retryLastCommand
public void retryLastCommand(int aCommand, Endpoint anEndpoint, java.lang.String aCasReferenceId)
- Specified by:
retryLastCommand
in interfaceAggregateAnalysisEngineController
-
getServiceErrors
public ServiceErrors getServiceErrors(java.lang.String aDelegateKey)
-
getServiceInfo
public AggregateServiceInfo getServiceInfo()
- Specified by:
getServiceInfo
in interfaceAggregateAnalysisEngineController
- Specified by:
getServiceInfo
in interfaceAnalysisEngineController
-
getServicePerformance
public ServicePerformance getServicePerformance(java.lang.String aDelegateKey)
- Specified by:
getServicePerformance
in interfaceAggregateAnalysisEngineController
-
incrementAnalysisTime
public void incrementAnalysisTime(long anAnalysisTime)
Accumulate analysis time for the aggregate- Parameters:
anAnalysisTime
-
-
stopTimers
public void stopTimers()
- Specified by:
stopTimers
in interfaceAggregateAnalysisEngineController
-
requestForMetaSentToRemotes
public boolean requestForMetaSentToRemotes()
- Specified by:
requestForMetaSentToRemotes
in interfaceAggregateAnalysisEngineController
-
setRequestForMetaSentToRemotes
public void setRequestForMetaSentToRemotes()
- Specified by:
setRequestForMetaSentToRemotes
in interfaceAggregateAnalysisEngineController
-
cleanUp
public void cleanUp()
- Overrides:
cleanUp
in classBaseAnalysisEngineController
-
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 interfaceAnalysisEngineController
- Overrides:
stop
in classBaseAnalysisEngineController
-
getChildControllerList
public java.util.List getChildControllerList()
- Specified by:
getChildControllerList
in interfaceAggregateAnalysisEngineController
-
onInitialize
public void onInitialize()
Force all collocated delegates to perform any post-initialization steps.- Specified by:
onInitialize
in interfaceAnalysisEngineController
-
changeCollocatedDelegateState
public void changeCollocatedDelegateState(java.lang.String delegateKey, BaseAnalysisEngineController.ServiceState state) throws java.lang.Exception
- Specified by:
changeCollocatedDelegateState
in interfaceAggregateAnalysisEngineController
- Throws:
java.lang.Exception
-
dumpState
public void dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
- Specified by:
dumpState
in interfaceAnalysisEngineController
- Specified by:
dumpState
in classBaseAnalysisEngineController
-
getLocalCache
public LocalCache getLocalCache()
- Specified by:
getLocalCache
in interfaceAnalysisEngineController
- Overrides:
getLocalCache
in classBaseAnalysisEngineController
-
lookupDelegate
public Delegate lookupDelegate(java.lang.String aDelegateKey)
ReturnDelegate
object for a given delegate key.- Specified by:
lookupDelegate
in interfaceAggregateAnalysisEngineController
-
setCasLoggingDirectory
public void setCasLoggingDirectory(java.lang.String key, java.lang.String directory)
- Specified by:
setCasLoggingDirectory
in interfaceAggregateAnalysisEngineController
-
-