public interface IConnection
Modifier and Type | Method and Description |
---|---|
void |
close()
close this connection
|
Iterator<TaskMessage> |
recv(int flags,
int clientId)
receive a batch message iterator (consists taskId and payload)
|
void |
send(int taskId,
byte[] payload)
send a message with taskId and payload
|
void |
send(Iterator<TaskMessage> msgs)
send batch messages
|
Iterator<TaskMessage> recv(int flags, int clientId)
flags
- 0: block, 1: non-blockvoid send(int taskId, byte[] payload)
taskId
- task IDpayload
- void send(Iterator<TaskMessage> msgs)
msgs
- void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.