| Modifier and Type | Method and Description | 
|---|---|
void | 
SystemEventsListener.peerJoined(PeerCard peer)  | 
void | 
SystemEventsListener.peerLost(PeerCard peer)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
SimpleMessage.getReceivers()
To implement 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
ControlBroker.getmyPeerCard()
This method returns the PeerCard of the current MW instance 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<PeerCard,Map<String,Serializable>> | 
ControlBroker.findMatchingPeers(Map<String,Serializable> filter,
                 int limit,
                 int timeout)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ControlBroker.addNewPeer(SpaceDescriptor spaceDescriptor,
          PeerCard peer)  | 
void | 
ControlBroker.join(PeerCard spaceCoordinator,
    SpaceCard spaceCard)  | 
void | 
ControlBroker.joinRequest(SpaceCard spaceCard,
           PeerCard sender)  | 
void | 
ControlBroker.leaveSpace(PeerCard spaceCoordinator,
          SpaceCard spaceCard)  | 
void | 
ControlBroker.newPeerAdded(SpaceCard spaceCard,
            PeerCard peer)  | 
void | 
ControlBroker.peerFound(PeerCard peer)  | 
void | 
ControlBroker.peerLost(PeerCard sender)  | 
Map<String,Serializable> | 
ControlBroker.requestPeerAttributes(List<String> attributes,
                     PeerCard target,
                     int limit,
                     int timeout)  | 
void | 
ControlBroker.requestToInstallPart(byte[] partAsZip,
                    PeerCard target,
                    UAPPCard card)
This method allows to request the installation of an uApp part to a
 target node 
 | 
void | 
ControlBroker.requestToUninstallPart(PeerCard target,
                      UAPPCard card)
This method allows to request the installation of an uApp part to a
 target node 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ControlBroker.sendMessage(BrokerMessage msg,
           List<PeerCard> receivers)
Send a message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
BrokerMessage.getReceivers()  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
ConfigurationMessage.getReceivers() | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
ConfigurationMessage.isSentFrom(PeerCard sender)  | 
| Constructor and Description | 
|---|
ConfigurationMessage(ConfigurationMessage.ConfigurationMessageType mType,
                    PeerCard sender,
                    String propagateSerialized)
Create a new Configuration Message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
ControlMessage.getReceivers()
To implement 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
DeployMessage.getReceivers()
To implement 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
DistributedMWMessage.getReceivers() | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
SpaceMessage.getReceivers()
To implement 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
AbstractBus.getPeerCard()  | 
static PeerCard | 
AbstractBus.getPeerFromBusResourceURI(String uri)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard[] | 
BusMessage.getReceivers()  | 
PeerCard | 
BusMessage.getSender()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BusMessage.addReceiver(PeerCard pc)  | 
void | 
BusMessage.addReceivers(PeerCard[] receivers)  | 
static BusMessage | 
BusMessage.createP2PReply(String messageIDInReplyTo,
              PeerCard receiver,
              Object content,
              AbstractBus creator)
Create a reply message to the message with the given ID, with the content
 and receiver passed as a parameter. 
 | 
boolean | 
BusMessage.hasReceiver(PeerCard receiver)  | 
boolean | 
BusMessage.sentBySamePeerAs(PeerCard peer)  | 
void | 
BusMessage.setReceiver(PeerCard receiver)
If the given peer is not null, removes any existing receiver and adds the
 given peer as the only receiver. 
 | 
void | 
BusMessage.setSender(PeerCard sender)  | 
static void | 
BusMessage.setThisPeer(PeerCard peer)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BusMessage.setReceivers(List<PeerCard> receivers)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CommunicationConnector.multicast(ChannelMessage message,
         List<PeerCard> receivers)
Send multicast message to a list of recipients in the same group 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JGroupsCommunicationConnector.multicast(ChannelMessage message,
         List<PeerCard> receivers)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
ChannelMessage.getSender()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ChannelMessage.setSender(PeerCard sender)  | 
| Constructor and Description | 
|---|
ChannelMessage(PeerCard sender,
              String content,
              List channelNames)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
DummySpaceManager.getMyPeerCard()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,PeerCard> | 
DummySpaceManager.getPeers()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Serializable> | 
DummySpaceManager.getPeerAttributes(List<String> arg0,
                 PeerCard arg1)  | 
void | 
DummyCommunicationModule.send(ChannelMessage arg0,
    MessageListener arg1,
    PeerCard arg2)  | 
void | 
DummyCommunicationModule.send(ChannelMessage arg0,
    PeerCard arg1)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DummyCommunicationModule.sendAll(ChannelMessage arg0,
       List<PeerCard> arg1)  | 
void | 
DummyCommunicationModule.sendAll(ChannelMessage arg0,
       List<PeerCard> arg1,
       MessageListener arg2)  | 
| Constructor and Description | 
|---|
DummySpaceManager(PeerCard myCard)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Scope | 
Scope.instanceScope(String id,
             PeerCard peerCard)  | 
static Scope | 
Scope.moduleScope(String id,
           PeerCard pc,
           ModuleContext mc)  | 
| Constructor and Description | 
|---|
InstanceScope(String id,
             PeerCard pc)
Constructor for an entity residing in the same node (this). 
 | 
ModuleScope(String id,
           PeerCard pc,
           ModuleContext mc)
Constructor using default instance (this), and ModuleContext for module
 Id. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
SpaceDescriptor.getDeployManager()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceDescriptor.setDeployManager(PeerCard deployManager)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
SpaceManager.getMyPeerCard()
This method returns the PeerCard of the current MW instance 
 | 
PeerCard[] | 
MatchingResult.getPeers()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<PeerCard,List<Part>> | 
UAPPPackage.getDeploy()  | 
Map<String,PeerCard> | 
SpaceManager.getPeers()
This method return the list of neighborhood peers joined to the current
 Space. 
NOTE: The list does not contains the invoker  | 
| Modifier and Type | Method and Description | 
|---|---|
InstallationResults | 
InstallationResultsDetails.getDetailedResult(PeerCard peer,
                 Part part)  | 
Map<String,Serializable> | 
MatchingResult.getPeerAttribute(PeerCard peer)  | 
Map<String,Serializable> | 
SpaceManager.getPeerAttributes(List<String> attributes,
                 PeerCard target)  | 
void | 
DistributedMWEventHandler.handleMessage(PeerCard sender,
             DistributedMWMessage msg)  | 
void | 
DeployManagerEventHandler.installationPartNotification(UAPPCard uappCard,
                            String partID,
                            PeerCard peer,
                            UAPPPartStatus partStatus)
Method called back in order to notifiy the result of a request to install 
 | 
void | 
SpaceEventHandler.joinRequest(SpaceCard spaceCard,
           PeerCard sender)
This method allows the SpaceManager to manage a join request from a
 remote peer. 
 | 
void | 
SpaceEventHandler.peerFound(PeerCard peer)
Method called when a peer joins the Space managed by the
 SpaceManager 
 | 
void | 
SpaceListener.peerJoined(PeerCard peer)
Called when a peers joins the Space 
 | 
void | 
SpaceEventHandler.peerLost(PeerCard peer)
This method notifies to the coordinator that a peer wants to leave to the
 Space 
 | 
void | 
SpaceListener.peerLost(PeerCard peer)
Called when a Peer leaves the Space 
 | 
void | 
InstallationResultsDetails.setDetailedResult(PeerCard peer,
                 Part part,
                 InstallationResults result)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceEventHandler.setListOfPeers(Map<String,PeerCard> peer)
This method allows to configure the set of peers that actually join the
 Space managed or joined by this SpaceManager 
 | 
| Constructor and Description | 
|---|
UAPPPackage(String serviceId,
           String id,
           URI folder,
           Map<PeerCard,List<Part>> layout)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DeployManagerImpl.installationPartNotification(UAPPCard card,
                            String partID,
                            PeerCard peer,
                            UAPPPartStatus status)  | 
void | 
DeployManagerImpl.peerJoined(PeerCard peer)  | 
void | 
DeployManagerImpl.peerLost(PeerCard peer)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DistributedBusMemberListener.busMemberAdded(PeerCard origin,
              String busMemberID,
              String busName,
              BusMemberType memberType,
              String label,
              String comment)
Invoked when a new BusMember is registered in the bus. 
 | 
void | 
DistributedBusMemberListener.busMemberRemoved(PeerCard origin,
                String busMemberID)
Invoked when an existing BusMember is unregistered from the bus. 
 | 
void | 
DistributedLogListener.log(PeerCard origin,
   int logLevel,
   String module,
   String pkg,
   String cls,
   String method,
   Object[] msgPart,
   String t)
Log a new message. 
 | 
void | 
DistributedBusMemberListener.regParamsAdded(PeerCard origin,
              String busMemberID,
              Resource[] params)
Invoked when registration parameters of an existing BusMember are added. 
 | 
void | 
DistributedBusMemberListener.regParamsRemoved(PeerCard origin,
                String busMemberID,
                Resource[] params)
Invoked when registration parameters of an existing BusMember are
 removed. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DistributedBusMemberManager.addListener(DistributedBusMemberListener listener,
           List<PeerCard> nodes)
Add a new listener. 
 | 
void | 
DistributedLogManager.addListener(DistributedLogListener listener,
           List<PeerCard> nodes)  | 
void | 
DistributedBusMemberManager.removeListener(DistributedBusMemberListener listener,
              List<PeerCard> nodes)
Remove an existing listener. 
 | 
void | 
DistributedLogManager.removeListener(DistributedLogListener listener,
              List<PeerCard> nodes)  | 
| Modifier and Type | Field and Description | 
|---|---|
static PeerCard | 
DistributedMWManagerImpl.myPeer  | 
| Modifier and Type | Field and Description | 
|---|---|
protected HashMap<PeerCard,Set<T>> | 
ListenerHandler.listeners
Remote nodes that we have subscribed to. 
 | 
protected Set<PeerCard> | 
ListenerHandler.subscribers
Remote peers that have subscribed to messages from this node. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<PeerCard> | 
MySpaceListener.getPeers()
Get all peers, including this peer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ListenerHandler.AddListenerHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
ListenerHandler.RemoveListenerHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
LogListenerHandler.LogListenerMessageHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
BusMemberListenerHandler.BusMemberAddedMessageHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
BusMemberListenerHandler.BusMemberRemovedMessageHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
BusMemberListenerHandler.RegParamsAddedMessageHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
BusMemberListenerHandler.RegParamsRemovedMessageHandler.handle(PeerCard sender,
      Resource r)  | 
void | 
ListenerHandler.peerJoined(PeerCard peer)  | 
void | 
MySpaceListener.peerJoined(PeerCard peer)  | 
void | 
ListenerHandler.peerLost(PeerCard peer)  | 
void | 
MySpaceListener.peerLost(PeerCard peer)  | 
static void | 
DistributedMWManagerImpl.sendMessage(Resource r,
           PeerCard receiver)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DistributedMWManagerImpl.addListener(DistributedBusMemberListener listener,
           List<PeerCard> nodes)  | 
void | 
DistributedMWManagerImpl.addListener(DistributedLogListener listener,
           List<PeerCard> nodes)  | 
void | 
ListenerHandler.addListener(T listener,
           List<PeerCard> nodes)  | 
void | 
DistributedMWManagerImpl.removeListener(DistributedBusMemberListener listener,
              List<PeerCard> nodes)  | 
void | 
DistributedMWManagerImpl.removeListener(DistributedLogListener listener,
              List<PeerCard> nodes)  | 
void | 
ListenerHandler.removeListener(T listener,
              List<PeerCard> nodes)  | 
static void | 
DistributedMWManagerImpl.sendMessage(Resource r,
           List<PeerCard> receivers)  | 
static void | 
DistributedMWManagerImpl.sendMessage(Resource r,
           Set<PeerCard> receivers)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
SpaceManagerImpl.getMyPeerCard()  | 
PeerCard[] | 
MatchingResultImpl.getPeers()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,PeerCard> | 
SpaceManagerImpl.getPeers()  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Serializable> | 
MatchingResultImpl.getPeerAttribute(PeerCard peer)  | 
Map<String,Serializable> | 
SpaceManagerImpl.getPeerAttributes(List<String> attributes,
                 PeerCard target)  | 
void | 
SpaceManagerImpl.joinRequest(SpaceCard spaceCard,
           PeerCard peer)  | 
void | 
SpaceManagerImpl.peerFound(PeerCard peer)  | 
void | 
SpaceManagerImpl.peerLost(PeerCard peer)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceManagerImpl.setListOfPeers(Map<String,PeerCard> peers)  | 
| Constructor and Description | 
|---|
MatchingResultImpl(Map<PeerCard,Map<String,Serializable>> data)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceModule.addPeer(SpaceDescriptor spaceDescriptor,
       PeerCard peer)
This method allows to add a new Peer to the Space. 
 | 
void | 
SpaceModule.announceNewPeer(SpaceCard spaceCard,
               PeerCard peerCard)
This method propagates the event of new PeerAdded to the whole Space 
 | 
void | 
SpaceModule.joinSpace(PeerCard spaceCoordinator,
         SpaceCard spaceCard)
This method allows to join to an existing Space 
 | 
void | 
SpaceModule.leaveSpace(PeerCard spaceCoordinator,
          SpaceCard spaceCard)
This method allows to leave a Space 
 | 
void | 
SpaceModule.messageFromSpace(SpaceMessage message,
                PeerCard sender)
This method is called as soon as an SpaceMessage has been received 
 | 
void | 
CommunicationModule.send(ChannelMessage message,
    MessageListener listener,
    PeerCard receiver)
Unicast send 
 | 
void | 
CommunicationModule.send(ChannelMessage message,
    PeerCard receiver)
Unicast send to the Space Coordinator for joining operation 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CommunicationModule.sendAll(ChannelMessage message,
       List<PeerCard> receivers)
Multicast implementation of the send. 
 | 
void | 
CommunicationModule.sendAll(ChannelMessage message,
       List<PeerCard> receivers,
       MessageListener listener)
Multicast send 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CommunicationModuleImpl.send(ChannelMessage message,
    MessageListener listener,
    PeerCard receiver)
Unicast 
 | 
void | 
CommunicationModuleImpl.send(ChannelMessage message,
    PeerCard receiver)
Unicast 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CommunicationModuleImpl.sendAll(ChannelMessage message,
       List<PeerCard> recipients)
Multicast 
 | 
void | 
CommunicationModuleImpl.sendAll(ChannelMessage message,
       List<PeerCard> receivers,
       MessageListener listener)
Multicast 
 | 
| Constructor and Description | 
|---|
UnicastExecutor(ChannelMessage message,
               CommunicationConnector communicationConnector,
               PeerCard receiver,
               List<MessageListener> listeners,
               ModuleContext moduleContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpaceModuleImpl.addPeer(SpaceDescriptor spaceDescriptor,
       PeerCard newPeer)  | 
void | 
SpaceModuleImpl.announceNewPeer(SpaceCard spaceCard,
               PeerCard peerCard)  | 
void | 
SpaceModuleImpl.joinSpace(PeerCard spaceCoordinator,
         SpaceCard spaceCard)  | 
void | 
SpaceModuleImpl.leaveSpace(PeerCard spaceCoordinator,
          SpaceCard spaceCard)  | 
void | 
SpaceModuleImpl.messageFromSpace(SpaceMessage message,
                PeerCard sender)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceBus.CallInjector.brokerCall(String callerID,
          PeerCard receiver,
          BusMessage call)
Can be used by  
ServiceCallInjector to inject a
 ServiceCall to the bus. | 
ServiceResponse | 
ServiceCaller.inject(ServiceCall call,
      PeerCard receiver)
Can be used to inject a  
ServiceCall to the bus. | 
String | 
ServiceCaller.sendCall(ServiceCall call,
        PeerCard receiver)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected PeerCard | 
ServiceStrategy.theCoordinator  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceBusImpl.CallInjectorImpl.brokerCall(String callerID,
          PeerCard receiver,
          BusMessage call)  | 
void | 
ServiceStrategy.injectCall(String callerID,
          BusMessage call,
          PeerCard receiver)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
UIStrategyHandler.peerLost(PeerCard peer) | 
void | 
UIStrategyCaller.peerLost(PeerCard peer)
Coordinator will abort all pending request of the lost peer 
 | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
CoordinatedStrategy.getCoordinator()  | 
PeerCard | 
CoordinatedStrategy.CoordinatorAlreadyExistsException.getExistingCoordinator()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CoordinatedStrategy.peerJoined(PeerCard peer) | 
void | 
CoordinatedStrategy.peerLost(PeerCard peer) | 
protected void | 
CallBasedStrategy.placeAsynchronousRequest(PeerCard peer,
                        CallMessage<? extends CallBasedStrategy> callMessage)
Send an asynchronous request to memberID. 
 | 
protected Object | 
CallBasedStrategy.placeSynchronousRequest(PeerCard peer,
                       CallMessage<? extends CallBasedStrategy> callMessage)
Place a Synchronous request, The  
CallMessage is sent and the
 message is anotated as waiting for response, the calling thread will be
 set in a waiting state until either a response to the message is
 received, or the call is aborted. | 
void | 
CallBasedStrategy.sendAsynchronousResponse(PeerCard peer,
                        CallMessage<? extends CallBasedStrategy> response)  | 
protected void | 
EventBasedStrategy.sendEventToRemoteBusMember(PeerCard[] members,
                          EventMessage content)
Helper method to send a Multicast Event. 
 | 
protected void | 
EventBasedStrategy.sendEventToRemoteBusMember(PeerCard member,
                          EventMessage content)
Helper method to send a Unicast Event. 
 | 
void | 
CoordinatedStrategy.CoordinatorAlreadyExistsException.setExistingCoordinator(PeerCard existingCoordinator)  | 
| Modifier and Type | Field and Description | 
|---|---|
PeerCard | 
MemberData.origin  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BusMemberMonitor.busMemberAdded(PeerCard origin,
              String busMemberID,
              String busName,
              BusMemberType memberType,
              String label,
              String comment)  | 
void | 
BusMemberMonitor.busMemberRemoved(PeerCard origin,
                String busMemberID)  | 
void | 
BusMemberMonitor.regParamsAdded(PeerCard origin,
              String busMemberID,
              Resource[] params)  | 
void | 
BusMemberMonitor.regParamsRemoved(PeerCard origin,
                String busMemberID,
                Resource[] params)  | 
| Constructor and Description | 
|---|
MemberData(PeerCard origin,
          String busMemberID,
          String busName,
          BusMemberType memberType,
          String label,
          String comment)  | 
| Modifier and Type | Method and Description | 
|---|---|
PeerCard | 
MySpaceListener.getMyPeerCard()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MySpaceListener.peerJoined(PeerCard peer)  | 
void | 
MySpaceListener.peerLost(PeerCard peer)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BusMemberGui.add(PeerCard peer)  | 
void | 
BusMemberGui.remove(PeerCard peer)  | 
void | 
BusMemberPane.show(PeerCard peerCard)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Serializable> | 
IInstaller.getPeerAttributes(List<String> attributes,
                 PeerCard target)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,PeerCard> | 
Installer.getPeers()
get peers in Space from the SpaceManager 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Serializable> | 
Installer.getPeerAttributes(List<String> attributes,
                 PeerCard target)  | 
| Modifier and Type | Method and Description | 
|---|---|
static List<PeerCard> | 
DeploymentInfoController.getValidPeers(List<UAPPReqAtom> reqs,
             String PartId)  | 
Copyright © 2018 universAAL Consortium. All rights reserved.