public class RelayDiscoveryAgent extends DiscoveryAgent implements IRelayAwarenessService
agent, allcodecs, defaultcodecs, delay, excludes, fast, includes, killed, received_self, receiver, root, sender, started, timer
Constructor and Description |
---|
RelayDiscoveryAgent() |
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.
|
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
public void executeBody()
executeBody
in class DiscoveryAgent
public jadex.commons.future.IFuture<java.lang.Void> agentKilled()
agentKilled
in class DiscoveryAgent
public jadex.commons.future.IFuture<java.lang.Void> connected(java.lang.String address)
connected
in interface IRelayAwarenessService
address
- The relay address.public jadex.commons.future.IFuture<java.lang.Void> disconnected(java.lang.String address)
disconnected
in interface IRelayAwarenessService
address
- The relay address.protected jadex.commons.future.IFuture<java.lang.Void> sendInfo(boolean offline)
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 setIncludes(java.lang.String[] includes)
setIncludes
in interface jadex.bridge.service.types.awareness.IDiscoveryService
setIncludes
in class DiscoveryAgent
includes
- The includes.public void setExcludes(java.lang.String[] excludes)
setExcludes
in interface jadex.bridge.service.types.awareness.IDiscoveryService
setExcludes
in class DiscoveryAgent
excludes
- The excludes.public void republish()
republish
in interface jadex.bridge.service.types.awareness.IDiscoveryService
republish
in class DiscoveryAgent