fabric.messages

Interface MessageHandler

All Known Implementing Classes:

AbstractMessageServer, MessageToStoreHandler, MessageToWorkerHandler, RemoteCallManager

public interface MessageHandler

This interface acts as a visitor for Messages. It also documents the list of all messages that can be handled. The methods all have the form:

 public Response handle(Principal, Message)
   throws FabricException
 

and there is one such method for each message type that can be handled.

Method Summary

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

Method Detail

handle

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

Throws:

AccessException

handle

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

Throws:

ProtocolError

AccessException

handle

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

Throws:

TransactionCommitFailedException

handle

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

Throws:

ProtocolError

AccessException

handle

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

Throws:

ProtocolError

handle

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

Throws:

TransactionPrepareFailedException

handle

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

Throws:

ProtocolError

AccessException

handle

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

Throws:

ProtocolError

FabricGeneralSecurityException

handle

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

Throws:

ProtocolError

AccessException

handle

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

Throws:

ProtocolError

handle

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

Throws:

ProtocolError

AccessException

handle

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

Throws:

ProtocolError

RemoteCallException

handle

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

Throws:

ProtocolError

TakeOwnershipFailedException

handle

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

Throws:

ProtocolError