jadex.platform.service.awareness.discovery.message

Class MessageDiscoveryAgent

java.lang.Object

jadex.platform.service.awareness.discovery.DiscoveryAgent

jadex.platform.service.awareness.discovery.message.MessageDiscoveryAgent

All Implemented Interfaces:

jadex.bridge.service.types.awareness.IDiscoveryService, IMessageAwarenessService

public class MessageDiscoveryAgent
extends DiscoveryAgent
implements IMessageAwarenessService

Discovery agent that is based on message receipt. The message service announces the sender of each incoming message to the IMessageAwarenessService of this agent. The agent will announce the underlying platform and uses ping messages to its rms to check if it is still present.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<jadex.bridge.IComponentIdentifier,java.lang.Long>	announcements The map of announced component identifiers.

Fields inherited from class jadex.platform.service.awareness.discovery.DiscoveryAgent

agent, allcodecs, defaultcodecs, delay, excludes, fast, includes, killed, received_self, receiver, root, sender, started, timer

Constructor Summary

Constructors

Constructor and Description
MessageDiscoveryAgent()

Method Summary

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.

Methods inherited from class jadex.platform.service.awareness.discovery.DiscoveryAgent

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

announcements

protected java.util.Map<jadex.bridge.IComponentIdentifier,java.lang.Long> announcements

The map of announced component identifiers.

Constructor Detail

MessageDiscoveryAgent

public MessageDiscoveryAgent()

Method Detail

agentCreated

public jadex.commons.future.IFuture<java.lang.Void> agentCreated()

Init the agent.

Overrides:

agentCreated in class DiscoveryAgent

announceComponentIdentifier

public jadex.commons.future.IFuture<java.lang.Void> announceComponentIdentifier(jadex.bridge.ITransportComponentIdentifier ccid)

Announce a potentially new component identifier.

Specified by:

announceComponentIdentifier in interface IMessageAwarenessService

Parameters:

cid - The component identifier.

refreshComponentIdentifier

public void refreshComponentIdentifier(jadex.bridge.ITransportComponentIdentifier cid,
                                       long time)

Refresh a component identifier.

Parameters:

cid - The component identifier.

performAnnouncements

protected void performAnnouncements(jadex.bridge.ITransportComponentIdentifier cid)

Perform continuous announcements until no ping answers are received any longer.

createSendHandler

public SendHandler createSendHandler()

Create the send handler.

Specified by:

createSendHandler in class DiscoveryAgent

createReceiveHandler

public ReceiveHandler createReceiveHandler()

Create the receive handler.

Specified by:

createReceiveHandler in class DiscoveryAgent

initNetworkRessource

protected void initNetworkRessource()

(Re)init sending/receiving ressource.

Specified by:

initNetworkRessource in class DiscoveryAgent

terminateNetworkRessource

protected void terminateNetworkRessource()

Terminate sending/receiving ressource.

Specified by:

terminateNetworkRessource in class DiscoveryAgent

announceAwareness

public void announceAwareness(jadex.bridge.service.types.awareness.AwarenessInfo info)

Announce newly arrived awareness info to management service.