Class VmTransport
java.lang.Object
org.apache.uima.aae.spi.transport.vm.VmTransport
- All Implemented Interfaces:
UimaTransport
This class provides implementation for internal messaging between collocated Uima AS services. It
uses
UimaMessageDispatcher
to send messages to UimaMessageListener
.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addSpiListener
(SpiListener listener) This method registers a givenSpiListener
instance with the SPI.void
destroy()
protected ThreadPoolExecutor
Returns SPI DispatcherproduceMessage
(int aCommand, int aMessageType, String aMessageFrom) produceUimaMessageDispatcher
(UimaTransport aTransport) void
registerWithJMX
(AnalysisEngineController aController, String queueKind) void
startIt()
This method is called to start SPI.void
stopIt()
This method is called to stop SPI.
-
Constructor Details
-
VmTransport
-
-
Method Details
-
addSpiListener
Description copied from interface:UimaTransport
This method registers a givenSpiListener
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.- Specified by:
addSpiListener
in interfaceUimaTransport
- Parameters:
listener
- - SPI listener to receive events
-
produceMessage
- Specified by:
produceMessage
in interfaceUimaTransport
-
produceMessage
- Specified by:
produceMessage
in interfaceUimaTransport
-
startIt
Description copied from interface:UimaTransport
This method is called to start SPI.- Specified by:
startIt
in interfaceUimaTransport
- Throws:
UimaSpiException
- - any problems while starting the SPI
-
stopIt
Description copied from interface:UimaTransport
This method is called to stop SPI.- Specified by:
stopIt
in interfaceUimaTransport
- Throws:
UimaSpiException
- - any problems while stopping the SPI
-
destroy
public void destroy() -
getExecutorInstance
-
registerWithJMX
- Specified by:
registerWithJMX
in interfaceUimaTransport
-
getMessageDispatcher
- Throws:
UimaSpiException
-
getUimaMessageListener
- Specified by:
getUimaMessageListener
in interfaceUimaTransport
-
produceUimaMessageListener
- Specified by:
produceUimaMessageListener
in interfaceUimaTransport
- Throws:
UimaSpiException
-
getUimaMessageDispatcher
Description copied from interface:UimaTransport
Returns SPI Dispatcher- Specified by:
getUimaMessageDispatcher
in interfaceUimaTransport
- Returns:
- - instance of SPI Dispatcher
- Throws:
UimaSpiException
- - any problems while fetching Dispatcher
-
getUimaMessageDispatcher
- Specified by:
getUimaMessageDispatcher
in interfaceUimaTransport
- Throws:
UimaSpiException
-
produceUimaMessageDispatcher
public UimaVmMessageDispatcher produceUimaMessageDispatcher(UimaTransport aTransport) throws UimaSpiException - Specified by:
produceUimaMessageDispatcher
in interfaceUimaTransport
- Throws:
UimaSpiException
-