grinda.impl
Class CommunicationManager
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CommunicationManager
public CommunicationManager()
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.