fabric.messages

Class MessageToStoreHandler

java.lang.Object

fabric.messages.AbstractMessageServer

fabric.messages.MessageToStoreHandler

All Implemented Interfaces:

MessageHandler, java.lang.Runnable

public abstract class MessageToStoreHandler
extends AbstractMessageServer

This abstract class acts as a visitor for MessagesToStore. It also documents the list of all messages that a store 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 store handles.

Field Summary

Fields inherited from class fabric.messages.AbstractMessageServer

logger, name

Constructor Summary

Constructors

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

Method Summary

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

MessageToStoreHandler

public MessageToStoreHandler(java.lang.String name)

Method Detail

handle

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

Throws:

AccessException

handle

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

Throws:

AccessException

handle

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

Throws:

TransactionCommitFailedException

handle

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

Throws:

AccessException

handle

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

handle

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

Throws:

TransactionPrepareFailedException

handle

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

Throws:

AccessException

handle

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

Throws:

FabricGeneralSecurityException

handle

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

Throws:

AccessException

handle

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

Throws:

ProtocolError

handle

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

Throws:

ProtocolError

handle

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

Throws:

ProtocolError

handle

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

Throws:

ProtocolError

handle

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

Throws:

ProtocolError