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, startSendBehaviorpublic MasterSlaveSendHandler(DiscoveryAgent state)
public jadex.commons.future.IFuture<jadex.bridge.service.types.awareness.AwarenessInfo> createAwarenessInfo()
createAwarenessInfo in class SendHandlerpublic void send(jadex.bridge.service.types.awareness.AwarenessInfo info)
send in class SendHandlerpublic 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)