org.apache.catalina.tribes.transport.nio
public class NioSender extends AbstractSender implements DataSender
Version: 1.0
Field Summary | |
---|---|
protected XByteBuffer | ackbuf |
protected boolean | complete |
protected boolean | connecting |
protected byte[] | current |
protected static Log | log |
protected ByteBuffer | readbuf |
protected int | remaining |
protected Selector | selector |
protected SocketChannel | socketChannel |
protected ByteBuffer | writebuf |
Constructor Summary | |
---|---|
NioSender() |
Method Summary | |
---|---|
void | connect()
connect - blocking in this operation
|
void | disconnect()
disconnect
|
byte[] | getMessage() |
Selector | getSelector() |
boolean | isComplete() |
boolean | process(SelectionKey key, boolean waitForAck)
State machine to send data |
protected boolean | read(SelectionKey key) |
void | reset() |
void | setComplete(boolean complete) |
void | setMessage(byte[] data)
sendMessage
|
void | setMessage(byte[] data, int offset, int length) |
void | setSelector(Selector selector) |
protected boolean | write(SelectionKey key) |
Throws: IOException
UNKNOWN: Implement this org.apache.catalina.tribes.transport.IDataSender method
UNKNOWN: Implement this org.apache.catalina.tribes.transport.IDataSender method
Parameters: key SelectionKey
Returns: boolean
Throws: IOException
Parameters: data ChannelMessage
Throws: IOException
UNKNOWN: Implement this org.apache.catalina.tribes.transport.IDataSender method