org.apache.uima.aae.spi.transport.vm

Class UimaVmMessageDispatcher

java.lang.Object

org.apache.uima.aae.spi.transport.vm.UimaVmMessageDispatcher

All Implemented Interfaces:

UimaMessageDispatcher

public class UimaVmMessageDispatcher
extends Object
implements 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

Constructors

Constructor and Description
UimaVmMessageDispatcher(ThreadPoolExecutor anExecutor, UimaMessageListener aListener, String aKey)

Method Summary

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UimaVmMessageDispatcher

public UimaVmMessageDispatcher(ThreadPoolExecutor anExecutor,
                               UimaMessageListener aListener,
                               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 interface UimaMessageDispatcher

stop

public void stop()

Specified by:

stop in interface UimaMessageDispatcher