grinda.impl
Class CommunicationManager

java.lang.Object
  extended by grinda.impl.CommunicationManager
All Implemented Interfaces:
Communicator, PeerCommunicator

public class CommunicationManager
extends java.lang.Object
implements Communicator

Implements the communication with other peers

Version:
1.0
Author:
Sirio Capizzi

Constructor Summary
CommunicationManager()
           
 
Method Summary
 void disjoinPeer(java.lang.String address)
           
 int getCount()
           
 java.lang.String getEndpoint()
           
 void initialize()
           
 java.lang.String[] joinPeer(java.lang.String peerAddress, java.lang.String[] n)
           
 void manageSubscription(SubscriptionInfo i)
           
 java.lang.String[] neighbours()
           
 void notify(Notify message)
           
 void notifySpace(java.lang.String spaceName, TupleSpaceConfigurationParameter params)
           
 void receive(GrindaResponse m)
           
 GrindaResponse transmit(GrindaRequest m)
           
 void transmit(java.lang.Object msg, java.lang.String e)
           
 void transmit(java.lang.Object msg, java.lang.String[] e)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CommunicationManager

public CommunicationManager()
Method Detail

notify

public void notify(Notify message)
            throws java.rmi.RemoteException
Throws:
java.rmi.RemoteException

manageSubscription

public void manageSubscription(SubscriptionInfo i)
                        throws java.rmi.RemoteException
Specified by:
manageSubscription in interface Communicator
Throws:
java.rmi.RemoteException

notifySpace

public void notifySpace(java.lang.String spaceName,
                        TupleSpaceConfigurationParameter params)

transmit

public void transmit(java.lang.Object msg,
                     java.lang.String e)
Specified by:
transmit in interface PeerCommunicator

transmit

public void transmit(java.lang.Object msg,
                     java.lang.String[] e)
Specified by:
transmit in interface PeerCommunicator

getEndpoint

public java.lang.String getEndpoint()
Specified by:
getEndpoint in interface PeerCommunicator

initialize

public void initialize()
Specified by:
initialize in interface Communicator

getCount

public int getCount()
Specified by:
getCount in interface PeerCommunicator

neighbours

public java.lang.String[] neighbours()
Specified by:
neighbours in interface PeerCommunicator

transmit

public GrindaResponse transmit(GrindaRequest m)
                        throws java.rmi.RemoteException
Specified by:
transmit in interface Communicator
Throws:
java.rmi.RemoteException

receive

public void receive(GrindaResponse m)
             throws java.rmi.RemoteException
Specified by:
receive in interface Communicator
Throws:
java.rmi.RemoteException

disjoinPeer

public void disjoinPeer(java.lang.String address)
                 throws java.rmi.RemoteException
Specified by:
disjoinPeer in interface Communicator
Throws:
java.rmi.RemoteException

joinPeer

public java.lang.String[] joinPeer(java.lang.String peerAddress,
                                   java.lang.String[] n)
                            throws java.rmi.RemoteException
Specified by:
joinPeer in interface Communicator
Throws:
java.rmi.RemoteException


Copyright © 2006 Sirio Capizzi. All Rights Reserved.