public abstract class MasterSlaveSendHandler extends SendHandler
agent, sendid, timer
Constructor and Description |
---|
MasterSlaveSendHandler(DiscoveryAgent state)
Create a new lease time handling object.
|
Modifier and Type | Method and Description |
---|---|
jadex.commons.future.IFuture<jadex.bridge.service.types.awareness.AwarenessInfo> |
createAwarenessInfo()
Create the awareness info.
|
protected MasterSlaveDiscoveryAgent |
getAgent()
Get the agent.
|
void |
send(jadex.bridge.service.types.awareness.AwarenessInfo info)
Method to send messages.
|
abstract boolean |
send(byte[] data,
java.net.InetAddress address,
int port)
Send a packet.
|
int |
sendToDiscover(byte[] data)
Send/forward to discover.
|
abstract int |
sendToDiscover(byte[] data,
int maxsend)
Send/forward to discover.
|
void |
sendToLocals(byte[] data)
Send/forward to locals.
|
abstract void |
sendToMaster(byte[] data)
Send to local masters.
|
int |
sendToRemotes(byte[] data)
Send awareness info to remote scanner services.
|
int |
sendToRemotes(byte[] data,
int maxsend)
Send awareness info to remote scanner services.
|
getSendId, setSendId, startSendBehavior
public MasterSlaveSendHandler(DiscoveryAgent state)
public jadex.commons.future.IFuture<jadex.bridge.service.types.awareness.AwarenessInfo> createAwarenessInfo()
createAwarenessInfo
in class SendHandler
public void send(jadex.bridge.service.types.awareness.AwarenessInfo info)
send
in class SendHandler
public int sendToDiscover(byte[] data)
data
- The data to be send.public abstract int sendToDiscover(byte[] data, int maxsend)
data
- The data to be send.public int sendToRemotes(byte[] data)
data
- The data to be send.maxsend
- The maximum number of messages to send.public int sendToRemotes(byte[] data, int maxsend)
data
- The data to be send.maxsend
- The maximum number of messages to send.public abstract void sendToMaster(byte[] data)
data
- The data to be send.public void sendToLocals(byte[] data)
data
- The data to be send.protected MasterSlaveDiscoveryAgent getAgent()
public abstract boolean send(byte[] data, java.net.InetAddress address, int port)