Class UimaVmMessageDispatcher
- java.lang.Object
-
- org.apache.uima.aae.spi.transport.vm.UimaVmMessageDispatcher
-
- All Implemented Interfaces:
UimaMessageDispatcher
public class UimaVmMessageDispatcher extends java.lang.Object implements UimaMessageDispatcher
Uima message implementation ofUimaMessageDispatcher
. 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
Constructors Constructor Description UimaVmMessageDispatcher(java.util.concurrent.ThreadPoolExecutor anExecutor, UimaMessageListener aListener, java.lang.String aKey)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
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 Detail
-
UimaVmMessageDispatcher
public UimaVmMessageDispatcher(java.util.concurrent.ThreadPoolExecutor anExecutor, UimaMessageListener aListener, java.lang.String aKey)
-
-
Method Detail
-
dispatch
public void dispatch(UimaMessage message)
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
-
-