jadex.platform.service.awareness.discovery.registry

Class RegistryDiscoveryAgent

java.lang.Object

jadex.platform.service.awareness.discovery.DiscoveryAgent

jadex.platform.service.awareness.discovery.MasterSlaveDiscoveryAgent

jadex.platform.service.awareness.discovery.registry.RegistryDiscoveryAgent

All Implemented Interfaces:

jadex.bridge.service.types.awareness.IDiscoveryService

public class RegistryDiscoveryAgent
extends MasterSlaveDiscoveryAgent

The registry awareness uses a dedicated registry awareness service at which all nodes register. Communication is done only via masters. Slaves send their infos to their master, which forwards them to the registry. Also the registry only sends infos to the masters that distribute them to their slaves. This avoids sending the infos to all slaves over the network.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.net.InetAddress	address The registry internet address.
protected int	port The receiver port.
protected java.net.DatagramSocket	socket The socket to send/receive.

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

locals, remotes

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

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	createMasterId() Create the master id.
protected java.lang.String	createMasterId(java.net.InetAddress address, int port) Create the master id.
ReceiveHandler	createReceiveHandler() Create the receive handler.
SendHandler	createSendHandler() Create the send handler.
java.net.InetAddress	getAddress() Get the address.
protected java.lang.String	getMyMasterId() Get the local master id.
int	getPort() Get the port.
protected java.net.DatagramSocket	getSocket() Get or create a receiver socket.
void	initNetworkRessource() (Re)init receiving.
protected boolean	isMaster() Test if is master.
boolean	isRegistry() Get the registry.
boolean	isRegistry(java.net.InetAddress address, int port) Get the registry.
protected void	terminateNetworkRessource() Terminate receiving.

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

agentKilled, executeBody, getLocals, getRemotes

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

agentCreated, createAwarenessInfo, createAwarenessInfo, decodeObject, doWaitFor, encodeObject, 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

address

protected java.net.InetAddress address

The registry internet address.

port

protected int port

The receiver port.

socket

protected java.net.DatagramSocket socket

The socket to send/receive.

Constructor Detail

RegistryDiscoveryAgent

public RegistryDiscoveryAgent()

Method Detail

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

getAddress

public java.net.InetAddress getAddress()

Get the address.

Returns:

the address.

getPort

public int getPort()

Get the port.

Returns:

the port.

isRegistry

public boolean isRegistry()

Get the registry.

Returns:

the registry.

isRegistry

public boolean isRegistry(java.net.InetAddress address,
                          int port)

Get the registry.

Returns:

the registry.

isMaster

protected boolean isMaster()

Test if is master.

Specified by:

isMaster in class MasterSlaveDiscoveryAgent

createMasterId

protected java.lang.String createMasterId()

Create the master id.

Specified by:

createMasterId in class MasterSlaveDiscoveryAgent

getMyMasterId

protected java.lang.String getMyMasterId()

Get the local master id.

Specified by:

getMyMasterId in class MasterSlaveDiscoveryAgent

createMasterId

protected java.lang.String createMasterId(java.net.InetAddress address,
                                          int port)

Create the master id.

initNetworkRessource

public void initNetworkRessource()

(Re)init receiving.

Specified by:

initNetworkRessource in class DiscoveryAgent

terminateNetworkRessource

protected void terminateNetworkRessource()

Terminate receiving.

Specified by:

terminateNetworkRessource in class DiscoveryAgent

getSocket

protected java.net.DatagramSocket getSocket()

Get or create a receiver socket. Note, this method has to be synchronized. Is called from receiver as well as component thread.