grinda.impl.brokers
Class MasterSlaveTupleBroker

java.lang.Object
  grinda.impl.brokers.MasterSlaveTupleBroker

All Implemented Interfaces:

ClientListener, RequestListener, ResultListener, SubscriptionListener, TupleBroker, java.lang.Cloneable

public class MasterSlaveTupleBroker
extends java.lang.Object
implements TupleBroker

An implementation of a broker that considers peers being master or slaves. This broker is useful for cluster with a master and some slaves. The property named master.host contains the master's url.

Version:

1.0

Author:

Sirio Capizzi

Constructor Summary

MasterSlaveTupleBroker()

Method Summary

TupleSpaceResult	clientRequest(TupleSpaceOperation op, java.lang.String client) Called when the client performs an
java.lang.Object	clone()
protected TupleSpaceResult	executeOnLocalSpaces(TupleSpaceOperation op, java.lang.String client)
java.lang.Object	getID()
void	initialize(java.lang.String id, TupleSpaceConfigurationParameter[] c) initialize
GrindaResponse	peerRequest(GrindaRequest m) Called when a result arrives
void	peerResult(GrindaResponse m) Called when a result arrives
void	subscribe(TupleSpaceOperation op, java.lang.String h) subscribe
void	unsubscribe(TupleSpaceOperation op, java.lang.String h) unsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

MasterSlaveTupleBroker

public MasterSlaveTupleBroker()

Method Detail

clone

public java.lang.Object clone()

Specified by:

clone in interface TupleBroker

Overrides:

clone in class java.lang.Object

getID

public java.lang.Object getID()

clientRequest

public TupleSpaceResult clientRequest(TupleSpaceOperation op,
                                      java.lang.String client)
                               throws java.rmi.RemoteException

Description copied from interface: ClientListener

Called when the client performs an

Specified by:

clientRequest in interface ClientListener

Parameters:

op - TupleSpaceOperation

client - EndpointReferenceType

Returns:

InternalTuple

Throws:

java.rmi.RemoteException

To do:

Implement this grinda.impl.ClientListener method

initialize

public void initialize(java.lang.String id,
                       TupleSpaceConfigurationParameter[] c)

initialize

Specified by:

initialize in interface TupleBroker

Parameters:

c - initial configuration

peerRequest

public GrindaResponse peerRequest(GrindaRequest m)

Description copied from interface: RequestListener

Called when a result arrives

Specified by:

peerRequest in interface RequestListener

Parameters:

m - the message representing the result

Returns:

GrindaResponse

To do:

Implement this grinda.impl.RequestListener method

peerResult

public void peerResult(GrindaResponse m)

Description copied from interface: ResultListener

Called when a result arrives

Specified by:

peerResult in interface ResultListener

Parameters:

m - the message representing the result

To do:

Implement this grinda.impl.ResultListener method

subscribe

public void subscribe(TupleSpaceOperation op,
                      java.lang.String h)

subscribe

Specified by:

subscribe in interface SubscriptionListener

Parameters:

op - TupleSpaceOperation

h - EndpointReferenceType

To do:

Implement this grinda.impl.SubscriptionListener method

unsubscribe

public void unsubscribe(TupleSpaceOperation op,
                        java.lang.String h)

unsubscribe

Specified by:

unsubscribe in interface SubscriptionListener

Parameters:

op - TupleSpaceOperation

h - String

To do:

Implement this grinda.impl.SubscriptionListener method

executeOnLocalSpaces

protected TupleSpaceResult executeOnLocalSpaces(TupleSpaceOperation op,
                                                java.lang.String client)