Class UimaVmMessageDispatcher
java.lang.Object
org.apache.uima.aae.spi.transport.vm.UimaVmMessageDispatcher
- All Implemented Interfaces:
UimaMessageDispatcher
Uima message implementation of
UimaMessageDispatcher
. It uses a Java's Executor framework
to pass Uima messages to a collocated Uima AS service. Each message is processed in a seperate
thread provided by the Executor.-
Constructor Summary
ConstructorsConstructorDescriptionUimaVmMessageDispatcher
(ThreadPoolExecutor anExecutor, UimaMessageListener aListener, String aKey) -
Method Summary
Modifier and TypeMethodDescriptionvoid
dispatch
(UimaMessage message) This method is responsible for adding a Uima message to a queue which is shared with a collocated service.void
stop()
-
Constructor Details
-
UimaVmMessageDispatcher
public UimaVmMessageDispatcher(ThreadPoolExecutor anExecutor, UimaMessageListener aListener, String aKey)
-
-
Method Details
-
dispatch
This method is responsible for adding a Uima message to a queue which is shared with a collocated service. Each message is processed by the receiving service in a thread provided by the Executor.- Specified by:
dispatch
in interfaceUimaMessageDispatcher
-
stop
public void stop()- Specified by:
stop
in interfaceUimaMessageDispatcher
-