Modifier and Type | Method and Description |
---|---|
void |
SystemEventsListener.newPeerJoined(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(AALSpaceDescriptor spaceDescriptor,
PeerCard peer) |
void |
ControlBroker.join(PeerCard spaceCoordinator,
AALSpaceCard spaceCard) |
void |
ControlBroker.joinRequest(AALSpaceCard spaceCard,
PeerCard sender) |
void |
ControlBroker.leaveAALSpace(PeerCard spaceCoordinator,
AALSpaceCard spaceCard) |
void |
ControlBroker.newPeerAdded(AALSpaceCard 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 |
---|---|
PeerCard[] |
BrokerMessage.getReceivers() |
Modifier and Type | Method and Description |
---|---|
PeerCard[] |
AALSpaceMessage.getReceivers()
To implement
|
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 |
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 |
AALSpaceDescriptor.getDeployManager() |
Modifier and Type | Method and Description |
---|---|
void |
AALSpaceDescriptor.setDeployManager(PeerCard deployManager) |
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 |
AALSpaceManagerImpl.getMyPeerCard() |
PeerCard[] |
MatchingResultImpl.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<String,PeerCard> |
AALSpaceManagerImpl.getPeers() |
Modifier and Type | Method and Description |
---|---|
Map<String,Serializable> |
MatchingResultImpl.getPeerAttribute(PeerCard peer) |
Map<String,Serializable> |
AALSpaceManagerImpl.getPeerAttributes(List<String> attributes,
PeerCard target) |
void |
AALSpaceManagerImpl.joinRequest(AALSpaceCard spaceCard,
PeerCard peer) |
void |
AALSpaceManagerImpl.peerFound(PeerCard peer) |
void |
AALSpaceManagerImpl.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
AALSpaceManagerImpl.setListOfPeers(Map<String,PeerCard> peers) |
Constructor and Description |
---|
MatchingResultImpl(Map<PeerCard,Map<String,Serializable>> data) |
Modifier and Type | Method and Description |
---|---|
PeerCard |
AALSpaceManager.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> |
AALSpaceManager.getPeers()
This method return the list of neighborhood peers joined to the current
AALSpace.
|
Modifier and Type | Method and Description |
---|---|
InstallationResults |
InstallationResultsDetails.getDetailedResult(PeerCard peer,
Part part) |
Map<String,Serializable> |
MatchingResult.getPeerAttribute(PeerCard peer) |
Map<String,Serializable> |
AALSpaceManager.getPeerAttributes(List<String> attributes,
PeerCard target) |
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 |
AALSpaceEventHandler.joinRequest(AALSpaceCard spaceCard,
PeerCard sender)
This method allows the AALSpaceManager to manage a join request from a
remote peer.
|
void |
AALSpaceListener.newPeerJoined(PeerCard peer)
Called when a peers joins the AALSpace
|
void |
AALSpaceEventHandler.peerFound(PeerCard peer)
Method called when a peer joins the AALSpace managed by the
AALSpaceManager
|
void |
AALSpaceListener.peerLost(PeerCard peer)
Called when a Peer leaves the AALSpace
|
void |
AALSpaceEventHandler.peerLost(PeerCard peer)
This method notifies to the coordinator that a peer wants to leave to the
AALSpace
|
void |
InstallationResultsDetails.setDetailedResult(PeerCard peer,
Part part,
InstallationResults result) |
Modifier and Type | Method and Description |
---|---|
void |
AALSpaceEventHandler.setListOfPeers(Map<String,PeerCard> peer)
This method allows to configure the set of peers that actually join the
AAL Space managed or joined by this AALSpaceManager
|
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.newPeerJoined(PeerCard peer) |
void |
DeployManagerImpl.peerLost(PeerCard peer) |
Modifier and Type | Method and Description |
---|---|
void |
AALSpaceModule.addPeer(AALSpaceDescriptor aalSpaceDescriptor,
PeerCard peer)
This method allows to add a new Peer to the AALSpace.
|
void |
AALSpaceModule.announceNewPeer(AALSpaceCard aalSpaceCard,
PeerCard peerCard)
This method propagates the event of new PeerAdded to the whole AALSpace
|
void |
AALSpaceModule.joinAALSpace(PeerCard spaceCoordinator,
AALSpaceCard aalSpaceCard)
This method allows to join to an existing AALSpace
|
void |
AALSpaceModule.leaveAALSpace(PeerCard spaceCoordinator,
AALSpaceCard aalSpaceCard)
This method allows to leave an AALSpace
|
void |
AALSpaceModule.messageFromSpace(AALSpaceMessage message,
PeerCard sender)
This method is called as soon as an AALSpaceMessage 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 AALSpace 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 |
AALSpaceModuleImpl.addPeer(AALSpaceDescriptor spaceDescriptor,
PeerCard newPeer) |
void |
AALSpaceModuleImpl.announceNewPeer(AALSpaceCard spaceCard,
PeerCard peerCard) |
void |
AALSpaceModuleImpl.joinAALSpace(PeerCard spaceCoordinator,
AALSpaceCard spaceCard) |
void |
AALSpaceModuleImpl.leaveAALSpace(PeerCard spaceCoordinator,
AALSpaceCard spaceCard) |
void |
AALSpaceModuleImpl.messageFromSpace(AALSpaceMessage message,
PeerCard sender) |
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 |
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.newPeerJoined(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) |
Copyright © 2015 universAAL Consortium. All Rights Reserved.