lima.testing
Class TestRX
java.lang.Object
|
+--java.rmi.server.RemoteObject
|
+--java.rmi.server.RemoteServer
|
+--java.rmi.server.UnicastRemoteObject
|
+--lima.testing.TestRX
- All Implemented Interfaces:
- java.rmi.Remote, java.io.Serializable, WorkUnitSink
- public class TestRX
- extends java.rmi.server.UnicastRemoteObject
- implements WorkUnitSink
- See Also:
- Serialized Form
| Fields inherited from class java.rmi.server.RemoteObject |
ref |
|
Constructor Summary |
TestRX(lima.testing.WUProcessorTest wUProcessorTest)
|
|
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. |
| Methods inherited from class java.rmi.server.UnicastRemoteObject |
clone, exportObject, exportObject, exportObject, unexportObject |
| Methods inherited from class java.rmi.server.RemoteServer |
getClientHost, getLog, setLog |
| Methods inherited from class java.rmi.server.RemoteObject |
equals, getRef, hashCode, toString, toStub |
| Methods inherited from class java.lang.Object |
finalize, getClass, notify, notifyAll, wait, wait, wait |
TestRX
public TestRX(lima.testing.WUProcessorTest wUProcessorTest)
throws java.rmi.RemoteException
flush
public void flush(lima.distribution.WorkUnit w)
throws java.rmi.RemoteException
- Description copied from interface:
WorkUnitSink
- Flush the WorkUnit w back to the distribution system. Note that order is
not maintained.
- Specified by:
flush in interface WorkUnitSink
- Parameters:
w -
java.rmi.RemoteException- See Also:
WorkUnitSink.flush(lima.distribution.WorkUnit)
allDone
public void allDone()
throws java.rmi.RemoteException
- Description copied from interface:
WorkUnitSink
- Signals that all WorkUnits have been done.
- Specified by:
allDone in interface WorkUnitSink
java.rmi.RemoteException- See Also:
WorkUnitSink.allDone()