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

java.lang.Object
  extended by 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


Copyright © 2012. All Rights Reserved.