|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.uima.aae.controller.AnalysisEngineControllerAdapter
org.apache.uima.aae.controller.UimacppServiceController
public class UimacppServiceController
This bean functions as a proxy for a Uima C++ service. It starts the Uima C++ service given a UIMA descriptor, the input queue name, and environment settings required for the specific annotator and the Uima C++ runtime. On start up a socket connection is established between this instance of the proxy and the service. This connection is used for routing log message from the C++ service to the UIMA framework logger and to allow the proxy to send JMX and administrative requests such as shutdown.
Field Summary | |
---|---|
protected UimacppServiceManagement |
mbean
|
protected java.net.ServerSocket |
server
|
protected java.lang.Process |
uimacppProcess
|
Fields inherited from interface org.apache.uima.aae.controller.AnalysisEngineController |
---|
AEInstanceCount, CasPoolSize |
Constructor Summary | |
---|---|
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. |
Method Summary | |
---|---|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected java.net.ServerSocket server
protected java.lang.Process uimacppProcess
protected UimacppServiceManagement mbean
Constructor Detail |
---|
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
Method Detail |
---|
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |