public class MessageDiscoveryAgent extends DiscoveryAgent implements IMessageAwarenessService
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<jadex.bridge.IComponentIdentifier,java.lang.Long> |
announcements
The map of announced component identifiers.
|
agent, allcodecs, defaultcodecs, delay, excludes, fast, includes, killed, received_self, receiver, root, sender, started, timer
Constructor and Description |
---|
MessageDiscoveryAgent() |
Modifier and Type | Method and Description |
---|---|
jadex.commons.future.IFuture<java.lang.Void> |
agentCreated()
Init the agent.
|
void |
announceAwareness(jadex.bridge.service.types.awareness.AwarenessInfo info)
Announce newly arrived awareness info to management service.
|
jadex.commons.future.IFuture<java.lang.Void> |
announceComponentIdentifier(jadex.bridge.ITransportComponentIdentifier ccid)
Announce a potentially new component identifier.
|
ReceiveHandler |
createReceiveHandler()
Create the receive handler.
|
SendHandler |
createSendHandler()
Create the send handler.
|
protected void |
initNetworkRessource()
(Re)init sending/receiving ressource.
|
protected void |
performAnnouncements(jadex.bridge.ITransportComponentIdentifier cid)
Perform continuous announcements until no ping answers are received any longer.
|
void |
refreshComponentIdentifier(jadex.bridge.ITransportComponentIdentifier cid,
long time)
Refresh a component identifier.
|
protected void |
terminateNetworkRessource()
Terminate sending/receiving ressource.
|
agentKilled, createAwarenessInfo, createAwarenessInfo, createMasterId, decodeObject, doWaitFor, encodeObject, executeBody, getAllCodecs, getClockTime, getDefaultCodecs, getDelay, getExcludes, getIncludes, getMicroAgent, getReceiver, getRoot, getSender, isFast, isKilled, isStarted, republish, setDelay, setExcludes, setFast, setIncludes, setKilled, setRoot, setStarted
protected java.util.Map<jadex.bridge.IComponentIdentifier,java.lang.Long> announcements
public jadex.commons.future.IFuture<java.lang.Void> agentCreated()
agentCreated
in class DiscoveryAgent
public jadex.commons.future.IFuture<java.lang.Void> announceComponentIdentifier(jadex.bridge.ITransportComponentIdentifier ccid)
announceComponentIdentifier
in interface IMessageAwarenessService
cid
- The component identifier.public void refreshComponentIdentifier(jadex.bridge.ITransportComponentIdentifier cid, long time)
cid
- The component identifier.protected void performAnnouncements(jadex.bridge.ITransportComponentIdentifier cid)
public SendHandler createSendHandler()
createSendHandler
in class DiscoveryAgent
public ReceiveHandler createReceiveHandler()
createReceiveHandler
in class DiscoveryAgent
protected void initNetworkRessource()
initNetworkRessource
in class DiscoveryAgent
protected void terminateNetworkRessource()
terminateNetworkRessource
in class DiscoveryAgent
public void announceAwareness(jadex.bridge.service.types.awareness.AwarenessInfo info)