jadex.platform.service.awareness.discovery.relay

Class RelayDiscoveryAgent

java.lang.Object

jadex.platform.service.awareness.discovery.DiscoveryAgent

jadex.platform.service.awareness.discovery.relay.RelayDiscoveryAgent

All Implemented Interfaces:

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

public class RelayDiscoveryAgent
extends DiscoveryAgent
implements IRelayAwarenessService

Control the discovery mechanism of the relay transport.

Field Summary

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
RelayDiscoveryAgent()

Method Summary

Modifier and Type	Method and Description
jadex.commons.future.IFuture<java.lang.Void>	agentKilled() Deregister when agent is killed.
jadex.commons.future.IFuture<java.lang.Void>	connected(java.lang.String address) Let the awareness know that the transport connected to an address.
ReceiveHandler	createReceiveHandler() Create the receive handler.
SendHandler	createSendHandler() Create the send handler.
jadex.commons.future.IFuture<java.lang.Void>	disconnected(java.lang.String address) Let the awareness know that the transport was disconnected from an address.
void	executeBody() After starting, perform initial registration at server.
protected void	initNetworkRessource() (Re)init sending/receiving ressource.
void	republish() Republish the awareness info.
protected jadex.commons.future.IFuture<java.lang.Void>	sendInfo(boolean offline) Send an awareness info.
void	setExcludes(java.lang.String[] excludes) Set the excludes.
void	setIncludes(java.lang.String[] includes) Set the includes.
protected void	terminateNetworkRessource() Terminate sending/receiving ressource.

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

agentCreated, createAwarenessInfo, createAwarenessInfo, createMasterId, decodeObject, doWaitFor, encodeObject, getAllCodecs, getClockTime, getDefaultCodecs, getDelay, getExcludes, getIncludes, getMicroAgent, getReceiver, getRoot, getSender, isFast, isKilled, isStarted, setDelay, setFast, setKilled, setRoot, setStarted

Methods inherited from class java.lang.Object

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

Constructor Detail

RelayDiscoveryAgent

public RelayDiscoveryAgent()

Method Detail

executeBody

public void executeBody()

After starting, perform initial registration at server.

Overrides:

executeBody in class DiscoveryAgent

agentKilled

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

Deregister when agent is killed.

Overrides:

agentKilled in class DiscoveryAgent

Returns:

The result of the component.

connected

public jadex.commons.future.IFuture<java.lang.Void> connected(java.lang.String address)

Let the awareness know that the transport connected to an address.

Specified by:

connected in interface IRelayAwarenessService

Parameters:

address - The relay address.

disconnected

public jadex.commons.future.IFuture<java.lang.Void> disconnected(java.lang.String address)

Let the awareness know that the transport was disconnected from an address.

Specified by:

disconnected in interface IRelayAwarenessService

Parameters:

address - The relay address.

sendInfo

protected jadex.commons.future.IFuture<java.lang.Void> sendInfo(boolean offline)

Send an awareness info.

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

setIncludes

public void setIncludes(java.lang.String[] includes)

Set the includes.

Specified by:

setIncludes in interface jadex.bridge.service.types.awareness.IDiscoveryService

Overrides:

setIncludes in class DiscoveryAgent

Parameters:

includes - The includes.

setExcludes

public void setExcludes(java.lang.String[] excludes)

Set the excludes.

Specified by:

setExcludes in interface jadex.bridge.service.types.awareness.IDiscoveryService

Overrides:

setExcludes in class DiscoveryAgent

Parameters:

excludes - The excludes.

republish

public void republish()

Republish the awareness info. Called when some important property has changed, e.g. platform addresses.

Specified by:

republish in interface jadex.bridge.service.types.awareness.IDiscoveryService

Overrides:

republish in class DiscoveryAgent