grinda.impl.brokers
Class MasterSlaveTupleBroker

java.lang.Object
  extended by 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)


Copyright © 2006 Sirio Capizzi. All Rights Reserved.