org.hypergraphdb.peer.replication
Class RememberTaskServer

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

All Implemented Interfaces:

java.lang.Runnable, ActivityStateListener

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

A task that performs the "server" side of the REMEMBER action. The task only manages a single conversation (with the client). The task is usually created when a call for proposal is received and decides in the startup phase whether to send a proposal or not.

Author:

Cipri Costa

Nested Class Summary

static class

RememberTaskServer.RememberTaskServerFactory

Constructor Summary

RememberTaskServer(HyperGraphPeer thisPeer, StorageService storage, java.util.UUID taskId)

Method Summary

org.hypergraphdb.peer.replication.RememberTaskServer.State	doPropose(AbstractActivity<?> conversation)
org.hypergraphdb.peer.replication.RememberTaskServer.State	handleAccept(AbstractActivity<?> conversation) called when a conversation enters the Accepted state while the task is in the Started state.
org.hypergraphdb.peer.replication.RememberTaskServer.State	handleReject(AbstractActivity<?> conversation)

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

getPeerInterface, getTaskId, getThisPeer, handleMessage, setTaskId, stateChanged

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

RememberTaskServer

public RememberTaskServer(HyperGraphPeer thisPeer,
                          StorageService storage,
                          java.util.UUID taskId)

Method Detail

doPropose

public org.hypergraphdb.peer.replication.RememberTaskServer.State doPropose(AbstractActivity<?> conversation)

handleAccept

public org.hypergraphdb.peer.replication.RememberTaskServer.State handleAccept(AbstractActivity<?> conversation)

called when a conversation enters the Accepted state while the task is in the Started state.

Parameters:

conversation -

Returns:

handleReject

public org.hypergraphdb.peer.replication.RememberTaskServer.State handleReject(AbstractActivity<?> conversation)