org.jppf.comm.recovery
Class Reaper

java.lang.Object
  org.jppf.comm.recovery.Reaper

public class Reaper
extends Object

This class checks, at regular intervals, the recovery-specific connections to remote peers, and detects whether the corresponding peer is dead.

Author:

Laurent Cohen

Constructor Summary

Reaper(RecoveryServer server, int poolSize, long runInterval)
Initialize this reaper with the specified recovery server.

Method Summary

void	addReaperListener(ReaperListener listener) Add a listener to the list of listeners.
void	removeReaperListener(ReaperListener listener) Remove a listener from the list of listeners.

Methods inherited from class java.lang.Object

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

Constructor Detail

Reaper

public Reaper(RecoveryServer server,
              int poolSize,
              long runInterval)

Initialize this reaper with the specified recovery server.

Parameters:

server - the server that handles the connections to the remote peers.

poolSize - this reaper's thread pool size.

runInterval - the interval between two runs of this reaper.

Method Detail

addReaperListener

public void addReaperListener(ReaperListener listener)

Add a listener to the list of listeners.

Parameters:

listener - the listener to add.

removeReaperListener

public void removeReaperListener(ReaperListener listener)

Remove a listener from the list of listeners.

Parameters:

listener - the listener to remove.