org.apache.uima.aae.controller
public class UimacppServiceController extends AnalysisEngineControllerAdapter implements ControllerLifecycle, org.springframework.beans.factory.DisposableBean
Modifier and Type | Field and Description |
---|---|
protected UimacppServiceManagement |
mbean |
protected java.net.ServerSocket |
server |
protected java.lang.Process |
uimacppProcess |
AEInstanceCount, CasPoolSize
Constructor and Description |
---|
UimacppServiceController(org.apache.uima.util.Logger uimaLogger,
java.lang.String aeDescriptorFileName,
java.lang.String queueName,
java.lang.String mqHostName,
int mqPort,
java.lang.String mqChannel,
java.lang.String mqQueueMgr,
int numInstances,
java.util.Map<java.lang.String,java.lang.String> envVarMap,
int processCasErrorThreshhold,
int processCasErrorWindow,
boolean terminateOnCPCError,
JmxManagement jmxManagement) |
UimacppServiceController(org.apache.uima.util.Logger uimaLogger,
java.lang.String aeDescriptorFileName,
java.lang.String queueName,
java.lang.String mqHostName,
int mqPort,
java.lang.String mqChannel,
java.lang.String mqQueueMgr,
int numInstances,
java.util.Map<java.lang.String,java.lang.String> envVarMap,
int processCasErrorThreshhold,
int processCasErrorWindow,
boolean terminateOnCPCError,
JmxManagement jmxManagement,
int initialFsHeapSize)
Configure and start a Uima C++ service that connects to an WebSphereMQ queue broker.
|
UimacppServiceController(java.lang.String aeDescriptorFileName,
java.lang.String queueName,
java.lang.String brokerURL,
int numInstances,
int prefetchSize,
java.util.Map<java.lang.String,java.lang.String> envVarMap,
int processCasErrorThreshhold,
int processCasErrorWindow,
boolean terminateOnCPCError) |
UimacppServiceController(java.lang.String aeDescriptorFileName,
java.lang.String queueName,
java.lang.String brokerURL,
int numInstances,
int prefetchSize,
java.util.Map<java.lang.String,java.lang.String> envVarMap,
int processCasErrorThreshhold,
int processCasErrorWindow,
boolean terminateOnCPCError,
int initialFsHeapSize)
Configure and start a Uima C++ service that connects to an ActiveMQ queue broker.
|
Modifier and Type | Method and Description |
---|---|
void |
addControllerCallbackListener(ControllerCallbackListener aListener)
Register one or more listeners through which the controller can send notification of events.
|
void |
destroy()
Runs when spring undeploys this bean.
|
void |
dumpState(java.lang.StringBuffer buffer,
java.lang.String lbl1) |
java.util.ArrayList<ControllerCallbackListener> |
getCallbackListeners() |
java.lang.String |
getKey() |
java.lang.String |
getStatistics() |
protected void |
handleConnection(java.net.Socket inSock) |
boolean |
isStopped()
Returns true if the AnalysisEngineController has been (or is in the process of) shutdown.
|
static void |
main(java.lang.String[] args)
test
|
void |
quiesceAndStop() |
void |
removeControllerCallbackListener(ControllerCallbackListener aListener)
Removes named application listener.
|
void |
resetStatistics() |
void |
setStopped()
Called to set the state of the AnalysisEngineController to STOPPED.
|
void |
shutdown()
Shuts down the UIMA C++ service process.
|
void |
terminate()
Runs when UIMA EE client API undeploys this service.
|
addAbortedCasReferenceId, addEndpointToDoNotProcessList, addInputChannel, addServiceInfo, addTimeSnapshot, beginProcess, cacheClientEndpoint, changeState, collectionProcessComplete, dropCAS, dropCAS, dropStats, endProcess, evictExpiredEntries, forceTimeoutOnPendingCases, getAnalysisTime, getCasManagerWrapper, getCasStatistics, getChildUimaContext, getClientEndpoint, getComponentName, getControllerLatch, getCpuTime, getDeadClientMap, getErrorHandlerChain, getEventListener, getIdleTime, getIdleTimeBetweenProcessCalls, getIndex, getInProcessCache, getInputChannel, getInputChannel, getJmxContext, getJMXDomain, getLocalCache, getManagementInterface, getMonitor, getName, getOutputChannel, getParentController, getReplyInputChannel, getReplyTime, getServiceEndpointName, getServiceErrors, getServiceInfo, getServicePerformance, getState, getStats, getTime, getTimeSnapshot, getTransport, getTransport, getUimaEEAdminContext, getUimaMessageListener, handleDelegateLifeCycleEvent, incrementDeserializationTime, incrementSerializationTime, initialize, initializeVMTransport, isAwaitingCacheCallbackNotification, isCasMultiplier, isEndpointOnDontProcessList, isPrimitive, isTopLevelComponent, notifyListenersWithInitializationStatus, onInitialize, process, process, process, registerVmQueueWithJMX, releaseNextCas, saveReplyTime, saveTime, sendMetadata, setCasManager, setDeployDescriptor, setInputChannel, setOutputChannel, setUimaEEAdminContext, stop, takeAction
protected java.net.ServerSocket server
protected java.lang.Process uimacppProcess
protected UimacppServiceManagement mbean
public UimacppServiceController(java.lang.String aeDescriptorFileName, java.lang.String queueName, java.lang.String brokerURL, int numInstances, int prefetchSize, java.util.Map<java.lang.String,java.lang.String> envVarMap, int processCasErrorThreshhold, int processCasErrorWindow, boolean terminateOnCPCError, int initialFsHeapSize) throws org.apache.uima.resource.ResourceInitializationException
aeDescriptorFileName
- - UIMA analysis engine descriptor file.queueName
- - input queue namebrokerURL
- - queue broker URLnumInstances
- - number of instance of AEs to start in the service.prefetchSize
- - number of message to prefetchenvVarMap
- - enviroment variables to be set. These settings are valid only for the new process in
which C++ service will run.org.apache.uima.UIMAException
org.apache.uima.resource.ResourceInitializationException
public UimacppServiceController(java.lang.String aeDescriptorFileName, java.lang.String queueName, java.lang.String brokerURL, int numInstances, int prefetchSize, java.util.Map<java.lang.String,java.lang.String> envVarMap, int processCasErrorThreshhold, int processCasErrorWindow, boolean terminateOnCPCError) throws org.apache.uima.resource.ResourceInitializationException
org.apache.uima.resource.ResourceInitializationException
public UimacppServiceController(org.apache.uima.util.Logger uimaLogger, java.lang.String aeDescriptorFileName, java.lang.String queueName, java.lang.String mqHostName, int mqPort, java.lang.String mqChannel, java.lang.String mqQueueMgr, int numInstances, java.util.Map<java.lang.String,java.lang.String> envVarMap, int processCasErrorThreshhold, int processCasErrorWindow, boolean terminateOnCPCError, JmxManagement jmxManagement, int initialFsHeapSize) throws org.apache.uima.resource.ResourceInitializationException
uimaLogger
- aeDescriptorFileName
- mqQueueName
- mqHostName
- mqPort
- mqChannel
- mqQueueMgr
- numInstances
- envVarMap
- processCasErrorThreshhold
- processCasErrorWindow
- terminateOnCPCError
- mBeanServer
- org.apache.uima.resource.ResourceInitializationException
public UimacppServiceController(org.apache.uima.util.Logger uimaLogger, java.lang.String aeDescriptorFileName, java.lang.String queueName, java.lang.String mqHostName, int mqPort, java.lang.String mqChannel, java.lang.String mqQueueMgr, int numInstances, java.util.Map<java.lang.String,java.lang.String> envVarMap, int processCasErrorThreshhold, int processCasErrorWindow, boolean terminateOnCPCError, JmxManagement jmxManagement) throws org.apache.uima.resource.ResourceInitializationException
org.apache.uima.resource.ResourceInitializationException
public void shutdown() throws java.io.IOException, java.lang.InterruptedException
force
- - force or allow service to shutdown gracefully.java.io.IOException
java.lang.InterruptedException
public java.lang.String getStatistics() throws java.io.IOException
java.io.IOException
public void resetStatistics() throws java.io.IOException
java.io.IOException
protected void handleConnection(java.net.Socket inSock) throws java.io.IOException
java.io.IOException
public static void main(java.lang.String[] args)
args
- public void terminate()
terminate
in interface ControllerLifecycle
terminate
in class AnalysisEngineControllerAdapter
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
public void addControllerCallbackListener(ControllerCallbackListener aListener)
ControllerLifecycle
addControllerCallbackListener
in interface ControllerLifecycle
addControllerCallbackListener
in class AnalysisEngineControllerAdapter
aListener
- - application listener object to registerpublic void removeControllerCallbackListener(ControllerCallbackListener aListener)
ControllerLifecycle
removeControllerCallbackListener
in interface ControllerLifecycle
removeControllerCallbackListener
in class AnalysisEngineControllerAdapter
aListener
- - application listener to removepublic void quiesceAndStop()
quiesceAndStop
in interface AnalysisEngineController
quiesceAndStop
in class AnalysisEngineControllerAdapter
public boolean isStopped()
AnalysisEngineController
isStopped
in interface AnalysisEngineController
isStopped
in class AnalysisEngineControllerAdapter
public void setStopped()
AnalysisEngineController
setStopped
in interface AnalysisEngineController
setStopped
in class AnalysisEngineControllerAdapter
public java.util.ArrayList<ControllerCallbackListener> getCallbackListeners()
public java.lang.String getKey()
getKey
in interface AnalysisEngineController
public void dumpState(java.lang.StringBuffer buffer, java.lang.String lbl1)
dumpState
in interface AnalysisEngineController
Copyright © 2014. All Rights Reserved.