fabric.messages

Class MessageToWorkerHandler

java.lang.Object

fabric.messages.AbstractMessageServer

fabric.messages.MessageToWorkerHandler

All Implemented Interfaces:

MessageHandler, java.lang.Runnable

Direct Known Subclasses:

RemoteCallManager

public abstract class MessageToWorkerHandler
extends AbstractMessageServer

This abstract class acts as a visitor for MessagesToWorker. It also documents the list of all messages that a worker needs to be able to handle. The methods all have the form:

 public Response handle(Principal, Message)
   throws FabricException
 

and there is one such method for each message type that the worker handles.

Field Summary

Fields inherited from class fabric.messages.AbstractMessageServer

logger, name

Constructor Summary

Constructors

Constructor and Description
MessageToWorkerHandler(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
abstract AbortTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, AbortTransactionMessage msg)
AllocateMessage.Response	handle(RemoteIdentity<RemoteWorker> client, AllocateMessage msg)
abstract CommitTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, CommitTransactionMessage msg)
abstract DirtyReadMessage.Response	handle(RemoteIdentity<RemoteWorker> client, DirtyReadMessage msg)
DissemReadMessage.Response	handle(RemoteIdentity<RemoteWorker> client, DissemReadMessage msg)
GetCertChainMessage.Response	handle(RemoteIdentity<RemoteWorker> client, GetCertChainMessage msg)
abstract InterWorkerStalenessMessage.Response	handle(RemoteIdentity<RemoteWorker> client, InterWorkerStalenessMessage msg)
MakePrincipalMessage.Response	handle(RemoteIdentity<RemoteWorker> client, MakePrincipalMessage msg)
abstract ObjectUpdateMessage.Response	handle(RemoteIdentity<RemoteWorker> client, ObjectUpdateMessage msg)
abstract PrepareTransactionMessage.Response	handle(RemoteIdentity<RemoteWorker> client, PrepareTransactionMessage msg)
ReadMessage.Response	handle(RemoteIdentity<RemoteWorker> client, ReadMessage msg)
abstract RemoteCallMessage.Response	handle(RemoteIdentity<RemoteWorker> client, RemoteCallMessage msg)
StalenessCheckMessage.Response	handle(RemoteIdentity<RemoteWorker> client, StalenessCheckMessage msg)
abstract TakeOwnershipMessage.Response	handle(RemoteIdentity<RemoteWorker> client, TakeOwnershipMessage msg)

Methods inherited from class fabric.messages.AbstractMessageServer

createServerSocket, run

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageToWorkerHandler

public MessageToWorkerHandler(java.lang.String name)

Method Detail

handle

public abstract AbortTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                        AbortTransactionMessage msg)
                                                 throws AccessException

Throws:

AccessException

handle

public abstract CommitTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                         CommitTransactionMessage msg)
                                                  throws TransactionCommitFailedException

Throws:

TransactionCommitFailedException

handle

public abstract ObjectUpdateMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                    ObjectUpdateMessage msg)

handle

public abstract PrepareTransactionMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                          PrepareTransactionMessage msg)
                                                   throws TransactionPrepareFailedException

Throws:

TransactionPrepareFailedException

handle

public abstract DirtyReadMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                 DirtyReadMessage msg)
                                          throws AccessException

Throws:

AccessException

handle

public abstract RemoteCallMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                  RemoteCallMessage msg)
                                           throws RemoteCallException

Throws:

RemoteCallException

handle

public abstract TakeOwnershipMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                     TakeOwnershipMessage msg)
                                              throws TakeOwnershipFailedException

Throws:

TakeOwnershipFailedException

handle

public abstract InterWorkerStalenessMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                                            InterWorkerStalenessMessage msg)

handle

public final AllocateMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                             AllocateMessage msg)
                                      throws ProtocolError

Throws:

ProtocolError

handle

public final DissemReadMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                               DissemReadMessage msg)
                                        throws ProtocolError

Throws:

ProtocolError

handle

public GetCertChainMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                           GetCertChainMessage msg)
                                    throws ProtocolError

Throws:

ProtocolError

handle

public ReadMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                   ReadMessage msg)
                            throws ProtocolError

Throws:

ProtocolError

handle

public MakePrincipalMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                            MakePrincipalMessage msg)
                                     throws ProtocolError

Throws:

ProtocolError

handle

public StalenessCheckMessage.Response handle(RemoteIdentity<RemoteWorker> client,
                                             StalenessCheckMessage msg)
                                      throws ProtocolError

Throws:

ProtocolError