public abstract class AnalysisEngineControllerAdapter extends Object implements AnalysisEngineController
AEInstanceCount, CasPoolSize
Constructor and Description |
---|
AnalysisEngineControllerAdapter() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dumpState, getKey
public void addAbortedCasReferenceId(String casReferenceId)
addAbortedCasReferenceId
in interface AnalysisEngineController
public void addInputChannel(InputChannel anInputChannel) throws Exception
addInputChannel
in interface AnalysisEngineController
Exception
public void addServiceInfo(ServiceInfo serviceInfo)
addServiceInfo
in interface AnalysisEngineController
public void addTimeSnapshot(long snapshot, String key)
public void beginProcess(int msgType)
beginProcess
in interface AnalysisEngineController
public void cacheClientEndpoint(Endpoint anEndpoint)
cacheClientEndpoint
in interface AnalysisEngineController
public void collectionProcessComplete(Endpoint anEndpoint) throws AsynchAEException
collectionProcessComplete
in interface AnalysisEngineController
AsynchAEException
public void dropCAS(String casReferenceId, boolean dropCacheEntry)
dropCAS
in interface AnalysisEngineController
public void dropCAS(org.apache.uima.cas.CAS acas)
dropCAS
in interface AnalysisEngineController
public void dropStats(String casReferenceId, String anEndpointName)
dropStats
in interface AnalysisEngineController
public void endProcess(int msgType)
endProcess
in interface AnalysisEngineController
public void forceTimeoutOnPendingCases(String key)
forceTimeoutOnPendingCases
in interface AnalysisEngineController
public long getAnalysisTime()
getAnalysisTime
in interface AnalysisEngineController
public AsynchAECasManager getCasManagerWrapper()
getCasManagerWrapper
in interface AnalysisEngineController
public ServicePerformance getCasStatistics(String casReferenceId)
getCasStatistics
in interface AnalysisEngineController
public org.apache.uima.UimaContext getChildUimaContext(String delegateEndpointName) throws Exception
getChildUimaContext
in interface AnalysisEngineController
Exception
public Endpoint getClientEndpoint()
getClientEndpoint
in interface AnalysisEngineController
public String getComponentName()
getComponentName
in interface AnalysisEngineController
public Map<String,String> getDeadClientMap()
getDeadClientMap
in interface AnalysisEngineController
public ControllerLatch getControllerLatch()
getControllerLatch
in interface AnalysisEngineController
public long getCpuTime()
getCpuTime
in interface AnalysisEngineController
public ErrorHandlerChain getErrorHandlerChain()
getErrorHandlerChain
in interface AnalysisEngineController
public EventSubscriber getEventListener()
getEventListener
in interface AnalysisEngineController
public long getIdleTime()
getIdleTime
in interface AnalysisEngineController
public long getIdleTimeBetweenProcessCalls(int msgType)
getIdleTimeBetweenProcessCalls
in interface AnalysisEngineController
public InProcessCache getInProcessCache()
getInProcessCache
in interface AnalysisEngineController
public int getIndex()
getIndex
in interface AnalysisEngineController
public InputChannel getInputChannel()
getInputChannel
in interface AnalysisEngineController
public InputChannel getInputChannel(String queueName)
getInputChannel
in interface AnalysisEngineController
public String getJMXDomain()
getJMXDomain
in interface AnalysisEngineController
public String getJmxContext()
getJmxContext
in interface AnalysisEngineController
public LocalCache getLocalCache()
getLocalCache
in interface AnalysisEngineController
public JmxManagement getManagementInterface()
getManagementInterface
in interface AnalysisEngineController
public Monitor getMonitor()
getMonitor
in interface AnalysisEngineController
public String getName()
getName
in interface AnalysisEngineController
public OutputChannel getOutputChannel()
getOutputChannel
in interface AnalysisEngineController
public AnalysisEngineController getParentController()
getParentController
in interface AnalysisEngineController
public InputChannel getReplyInputChannel(String delegateKey)
getReplyInputChannel
in interface AnalysisEngineController
public long getReplyTime()
getReplyTime
in interface AnalysisEngineController
public String getServiceEndpointName()
getServiceEndpointName
in interface AnalysisEngineController
public ServiceErrors getServiceErrors()
getServiceErrors
in interface AnalysisEngineController
public ServiceInfo getServiceInfo()
getServiceInfo
in interface AnalysisEngineController
public ServicePerformance getServicePerformance()
getServicePerformance
in interface AnalysisEngineController
public Map getStats()
getStats
in interface AnalysisEngineController
public long getTime(String casReferenceId, String anEndpointName)
getTime
in interface AnalysisEngineController
public long getTimeSnapshot(String key)
public UimaTransport getTransport(UimaAsContext context, String key) throws Exception
getTransport
in interface AnalysisEngineController
Exception
public UimaTransport getTransport(String key) throws Exception
getTransport
in interface AnalysisEngineController
Exception
public UimaEEAdminContext getUimaEEAdminContext()
getUimaEEAdminContext
in interface AnalysisEngineController
public UimaMessageListener getUimaMessageListener(String delegateKey)
getUimaMessageListener
in interface AnalysisEngineController
public void handleDelegateLifeCycleEvent(String anEndpoint, int delegateCount)
handleDelegateLifeCycleEvent
in interface AnalysisEngineController
public void incrementDeserializationTime(long cpuTime)
incrementDeserializationTime
in interface AnalysisEngineController
public void incrementSerializationTime(long cpuTime)
incrementSerializationTime
in interface AnalysisEngineController
public void initialize() throws AsynchAEException
initialize
in interface AnalysisEngineController
AsynchAEException
public void initializeVMTransport(int parentControllerReplyConsumerCount) throws Exception
initializeVMTransport
in interface AnalysisEngineController
Exception
public boolean isAwaitingCacheCallbackNotification()
isAwaitingCacheCallbackNotification
in interface AnalysisEngineController
public boolean isCasMultiplier()
isCasMultiplier
in interface AnalysisEngineController
public boolean isPrimitive()
isPrimitive
in interface AnalysisEngineController
public boolean isStopped()
AnalysisEngineController
isStopped
in interface AnalysisEngineController
public boolean isTopLevelComponent()
isTopLevelComponent
in interface AnalysisEngineController
public void notifyListenersWithInitializationStatus(Exception e)
notifyListenersWithInitializationStatus
in interface AnalysisEngineController
public void onInitialize()
onInitialize
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS cas, String casId)
process
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS acas, String anInputCasReferenceId, String newCasReferenceId, String newCASProducedBy)
process
in interface AnalysisEngineController
public void process(org.apache.uima.cas.CAS acas, String casReferenceId, Endpoint anEndpoint)
process
in interface AnalysisEngineController
public abstract void quiesceAndStop()
quiesceAndStop
in interface AnalysisEngineController
public void registerVmQueueWithJMX(Object o, String name) throws Exception
registerVmQueueWithJMX
in interface AnalysisEngineController
Exception
public void releaseNextCas(String casReferenceId)
releaseNextCas
in interface AnalysisEngineController
public void saveReplyTime(long snapshot, String key)
saveReplyTime
in interface AnalysisEngineController
public void saveTime(long anArrivalTime, String casReferenceId, String anEndpointName)
saveTime
in interface AnalysisEngineController
public void sendMetadata(Endpoint anEndpoint) throws AsynchAEException
sendMetadata
in interface AnalysisEngineController
AsynchAEException
public void setCasManager(AsynchAECasManager casManager)
setCasManager
in interface AnalysisEngineController
public void setDeployDescriptor(String deployDescriptor)
setDeployDescriptor
in interface AnalysisEngineController
public void setInputChannel(InputChannel anInputChannel) throws Exception
setInputChannel
in interface AnalysisEngineController
Exception
public void setOutputChannel(OutputChannel anOutputChannel) throws Exception
setOutputChannel
in interface AnalysisEngineController
Exception
public void setStopped()
AnalysisEngineController
setStopped
in interface AnalysisEngineController
public void setUimaEEAdminContext(UimaEEAdminContext anAdminContext)
setUimaEEAdminContext
in interface AnalysisEngineController
public void stop()
stop
in interface AnalysisEngineController
public void takeAction(String anAction, String anEndpointName, ErrorContext anErrorContext)
takeAction
in interface AnalysisEngineController
public void addControllerCallbackListener(ControllerCallbackListener listener)
ControllerLifecycle
addControllerCallbackListener
in interface ControllerLifecycle
listener
- - application listener object to registerpublic void removeControllerCallbackListener(ControllerCallbackListener listener)
ControllerLifecycle
removeControllerCallbackListener
in interface ControllerLifecycle
listener
- - application listener to removepublic void terminate()
ControllerLifecycle
terminate
in interface ControllerLifecycle
public void addEndpointToDoNotProcessList(String anEndpointName)
public boolean isEndpointOnDontProcessList(String anEndpointName)
public void evictExpiredEntries()
public void changeState(BaseAnalysisEngineController.ServiceState state)
changeState
in interface AnalysisEngineController
public BaseAnalysisEngineController.ServiceState getState()
getState
in interface AnalysisEngineController
Copyright © 2017. All rights reserved.