org.apache.qpid.transport.network.io
Class IoSender
java.lang.Object
org.apache.qpid.transport.network.io.IoSender
- All Implemented Interfaces:
- Runnable, Sender<ByteBuffer>
public final class IoSender
- extends Object
- implements Runnable, Sender<ByteBuffer>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IoSender
public IoSender(IoContext ioCtx,
int bufferSize,
long timeout)
send
public void send(ByteBuffer buf)
- Specified by:
send
in interface Sender<ByteBuffer>
flush
public void flush()
- Specified by:
flush
in interface Sender<ByteBuffer>
close
public void close()
- Specified by:
close
in interface Sender<ByteBuffer>
close
void close(boolean reportException)
run
public void run()
- Specified by:
run
in interface Runnable
setIdleTimeout
public void setIdleTimeout(int i)
- Specified by:
setIdleTimeout
in interface Sender<ByteBuffer>
Licensed to the Apache Software Foundation