public abstract class ReceiveHandler
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected DiscoveryAgent |
agent
The agent.
|
protected boolean |
received_self
Flag indicating that the agent has received its own discovery info.
|
protected java.lang.String |
sendid
The current send id.
|
Constructor and Description |
---|
ReceiveHandler(DiscoveryAgent agent)
Create a new lease time handling object.
|
Modifier and Type | Method and Description |
---|---|
void |
announceAwareness(jadex.bridge.service.types.awareness.AwarenessInfo info)
Announce newly arrived awareness info to management service.
|
void |
handleReceivedPacket(java.net.InetAddress address,
int port,
byte[] data,
jadex.bridge.service.types.awareness.AwarenessInfo info)
Handle a received packet.
|
abstract java.lang.Object[] |
receive()
Receive a packet.
|
jadex.commons.future.IFuture<java.lang.Void> |
startReceiving()
Start receiving awareness infos.
|
protected DiscoveryAgent agent
protected java.lang.String sendid
protected boolean received_self
public ReceiveHandler(DiscoveryAgent agent)
public abstract java.lang.Object[] receive() throws java.lang.Exception
java.lang.Exception
public jadex.commons.future.IFuture<java.lang.Void> startReceiving()
public void handleReceivedPacket(java.net.InetAddress address, int port, byte[] data, jadex.bridge.service.types.awareness.AwarenessInfo info)
public void announceAwareness(jadex.bridge.service.types.awareness.AwarenessInfo info)