lima.distribution
Interface WorkUnitSink

All Superinterfaces:

java.rmi.Remote

All Known Implementing Classes:

EcmSink, QSWorkUnitSink, TestRX, TestWUPipe

public interface WorkUnitSink

extends java.rmi.Remote

A sink for Processed WorkUnits. When a WorkUnitProcessor has a finished WorkUnit, it will pass it back to the caller through this call back.

Method Summary

void	allDone() Signals that all WorkUnits have been done.
void	flush(lima.distribution.WorkUnit w) Flush the WorkUnit w back to the distribution system.

Method Detail

flush

public void flush(lima.distribution.WorkUnit w)
           throws java.rmi.RemoteException

Flush the WorkUnit w back to the distribution system. Note that order is not maintained.

Parameters:

w -

java.rmi.RemoteException

allDone

public void allDone()
             throws java.rmi.RemoteException

Signals that all WorkUnits have been done.

java.rmi.RemoteException