public class VmTransport extends java.lang.Object implements UimaTransport
UimaMessageDispatcher
to send messages to UimaMessageListener
.Constructor and Description |
---|
VmTransport(UimaAsContext aContext,
AnalysisEngineController aController) |
Modifier and Type | Method and Description |
---|---|
void |
addSpiListener(SpiListener listener)
This method registers a given
SpiListener instance with the SPI. |
void |
destroy() |
protected java.util.concurrent.ThreadPoolExecutor |
getExecutorInstance() |
UimaMessageDispatcher |
getMessageDispatcher() |
UimaMessageDispatcher |
getUimaMessageDispatcher()
Returns SPI Dispatcher
|
UimaMessageDispatcher |
getUimaMessageDispatcher(java.lang.String aKey) |
UimaMessageListener |
getUimaMessageListener() |
UimaVmMessage |
produceMessage() |
UimaVmMessage |
produceMessage(int aCommand,
int aMessageType,
java.lang.String aMessageFrom) |
UimaVmMessageDispatcher |
produceUimaMessageDispatcher(UimaTransport aTransport) |
UimaMessageListener |
produceUimaMessageListener() |
void |
registerWithJMX(AnalysisEngineController aController,
java.lang.String queueKind) |
void |
startIt()
This method is called to start SPI.
|
void |
stopIt()
This method is called to stop SPI.
|
public VmTransport(UimaAsContext aContext, AnalysisEngineController aController)
public void addSpiListener(SpiListener listener)
UimaTransport
SpiListener
instance with the SPI. The SPI will call all
registered listeners when the initialization is completed, when the start is completed, and
when the stop is completed.addSpiListener
in interface UimaTransport
listener
- - SPI listener to receive eventspublic UimaVmMessage produceMessage()
produceMessage
in interface UimaTransport
public UimaVmMessage produceMessage(int aCommand, int aMessageType, java.lang.String aMessageFrom)
produceMessage
in interface UimaTransport
public void startIt() throws UimaSpiException
UimaTransport
startIt
in interface UimaTransport
UimaSpiException
- - any problems while starting the SPIpublic void stopIt() throws UimaSpiException
UimaTransport
stopIt
in interface UimaTransport
UimaSpiException
- - any problems while stopping the SPIpublic void destroy()
protected java.util.concurrent.ThreadPoolExecutor getExecutorInstance()
public void registerWithJMX(AnalysisEngineController aController, java.lang.String queueKind)
registerWithJMX
in interface UimaTransport
public UimaMessageDispatcher getMessageDispatcher() throws UimaSpiException
UimaSpiException
public UimaMessageListener getUimaMessageListener()
getUimaMessageListener
in interface UimaTransport
public UimaMessageListener produceUimaMessageListener() throws UimaSpiException
produceUimaMessageListener
in interface UimaTransport
UimaSpiException
public UimaMessageDispatcher getUimaMessageDispatcher() throws UimaSpiException
UimaTransport
getUimaMessageDispatcher
in interface UimaTransport
UimaSpiException
- - any problems while fetching Dispatcherpublic UimaMessageDispatcher getUimaMessageDispatcher(java.lang.String aKey) throws UimaSpiException
getUimaMessageDispatcher
in interface UimaTransport
UimaSpiException
public UimaVmMessageDispatcher produceUimaMessageDispatcher(UimaTransport aTransport) throws UimaSpiException
produceUimaMessageDispatcher
in interface UimaTransport
UimaSpiException
Copyright © 2012. All Rights Reserved.