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 java.lang.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

UimaVmMessageDispatcher(java.util.concurrent.ThreadPoolExecutor anExecutor, UimaMessageListener aListener, java.lang.String aKey)

Method Summary

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(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 interface UimaMessageDispatcher

stop

public void stop()

Specified by:

stop in interface UimaMessageDispatcher