public interface AnalysisEngineController extends ControllerLifecycle
Modifier and Type | Field and Description |
---|---|
static String |
AEInstanceCount |
static String |
CasPoolSize |
addControllerCallbackListener, removeControllerCallbackListener, terminate
static final String CasPoolSize
static final String AEInstanceCount
void sendMetadata(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
ControllerLatch getControllerLatch()
void setInputChannel(InputChannel anInputChannel) throws Exception
Exception
void addInputChannel(InputChannel anInputChannel) throws Exception
Exception
String getServiceEndpointName()
void handleDelegateLifeCycleEvent(String anEndpoint, int aDelegateCount)
void takeAction(String anAction, String anEndpointName, ErrorContext anErrorContext)
InputChannel getInputChannel()
InputChannel getInputChannel(String aQueueName)
void saveReplyTime(long snapshot, String aKey)
long getReplyTime()
Map getStats()
org.apache.uima.UimaContext getChildUimaContext(String aDelegateEndpointName) throws Exception
Exception
void dropCAS(String aCasReferenceId, boolean dropCacheEntry)
void dropCAS(org.apache.uima.cas.CAS aCAS)
InProcessCache getInProcessCache()
boolean isPrimitive()
Monitor getMonitor()
String getName()
String getComponentName()
void collectionProcessComplete(Endpoint anEndpoint) throws AsynchAEException
AsynchAEException
boolean isTopLevelComponent()
void initialize() throws AsynchAEException
AsynchAEException
void process(org.apache.uima.cas.CAS aCas, String aCasId)
void process(org.apache.uima.cas.CAS aCAS, String anInputCasReferenceId, String aNewCasReferenceId, String newCASProducedBy)
ErrorHandlerChain getErrorHandlerChain()
void setOutputChannel(OutputChannel anOutputChannel) throws Exception
Exception
OutputChannel getOutputChannel()
void setCasManager(AsynchAECasManager aCasManager)
AsynchAECasManager getCasManagerWrapper()
void stop()
boolean isStopped()
void setStopped()
void setUimaEEAdminContext(UimaEEAdminContext anAdminContext)
UimaEEAdminContext getUimaEEAdminContext()
String getJMXDomain()
int getIndex()
String getJmxContext()
ServicePerformance getServicePerformance()
ServiceInfo getServiceInfo()
void addServiceInfo(ServiceInfo aServiceInfo)
ServiceErrors getServiceErrors()
void setDeployDescriptor(String aDeployDescriptor)
void cacheClientEndpoint(Endpoint anEndpoint)
Endpoint getClientEndpoint()
EventSubscriber getEventListener()
JmxManagement getManagementInterface()
void notifyListenersWithInitializationStatus(Exception e)
ServicePerformance getCasStatistics(String aCasReferenceId)
boolean isCasMultiplier()
void releaseNextCas(String aCasReferenceId)
long getIdleTime()
void beginProcess(int msgType)
void endProcess(int msgType)
long getIdleTimeBetweenProcessCalls(int msgType)
long getCpuTime()
long getAnalysisTime()
void incrementSerializationTime(long cpuTime)
void incrementDeserializationTime(long cpuTime)
void onInitialize()
UimaMessageListener getUimaMessageListener(String aDelegateKey)
UimaTransport getTransport(UimaAsContext aContext, String aKey) throws Exception
Exception
UimaTransport getTransport(String aKey) throws Exception
Exception
void initializeVMTransport(int parentControllerReplyConsumerCount) throws Exception
Exception
InputChannel getReplyInputChannel(String aDelegateKey)
LocalCache getLocalCache()
void registerVmQueueWithJMX(Object o, String aName) throws Exception
Exception
AnalysisEngineController getParentController()
void addAbortedCasReferenceId(String aCasReferenceId)
boolean isAwaitingCacheCallbackNotification()
void quiesceAndStop()
void forceTimeoutOnPendingCases(String key)
void changeState(BaseAnalysisEngineController.ServiceState state)
BaseAnalysisEngineController.ServiceState getState()
String getKey()
void dumpState(StringBuffer buffer, String lbl1)
Copyright © 2017. All rights reserved.