org.hypergraphdb.peer.replication
Class CatchUpTaskClient

java.lang.Object
  org.hypergraphdb.peer.workflow.AbstractActivity<StateType>
      org.hypergraphdb.peer.workflow.TaskActivity<org.hypergraphdb.peer.replication.CatchUpTaskClient.State>
          org.hypergraphdb.peer.replication.CatchUpTaskClient

All Implemented Interfaces:

java.lang.Runnable, ActivityStateListener

public class CatchUpTaskClient
extends TaskActivity<org.hypergraphdb.peer.replication.CatchUpTaskClient.State>

Author:

Cipri Costa Starts a catch up action with a given peer or with all known peers. It will send CatchUp requests to other peers with the current state and the interests of the peer. The other peers will initiate conversations to help this peer come up to date.

Constructor Summary

CatchUpTaskClient(HyperGraphPeer thisPeer, java.lang.Object catchUpWith)

Method Summary

org.hypergraphdb.peer.replication.CatchUpTaskClient.State	handleConfirm(AbstractActivity<?> fromActivity)
org.hypergraphdb.peer.replication.CatchUpTaskClient.State	handleDisconfirm(AbstractActivity<?> fromActivity)
void	stateChanged(java.lang.Object newState, AbstractActivity<?> activity)

Methods inherited from class org.hypergraphdb.peer.workflow.TaskActivity

getPeerInterface, getTaskId, getThisPeer, handleMessage, setTaskId

Methods inherited from class org.hypergraphdb.peer.workflow.AbstractActivity

getEndState, getStartState, run, setStateListener

Methods inherited from class java.lang.Object

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

Constructor Detail

CatchUpTaskClient

public CatchUpTaskClient(HyperGraphPeer thisPeer,
                         java.lang.Object catchUpWith)

Method Detail

stateChanged

public void stateChanged(java.lang.Object newState,
                         AbstractActivity<?> activity)

Specified by:

stateChanged in interface ActivityStateListener

Overrides:

stateChanged in class TaskActivity<org.hypergraphdb.peer.replication.CatchUpTaskClient.State>

handleConfirm

public org.hypergraphdb.peer.replication.CatchUpTaskClient.State handleConfirm(AbstractActivity<?> fromActivity)

handleDisconfirm

public org.hypergraphdb.peer.replication.CatchUpTaskClient.State handleDisconfirm(AbstractActivity<?> fromActivity)