org.apache.qpid.transport.network.io
Class IoSender

java.lang.Object
  extended by org.apache.qpid.transport.network.io.IoSender
All Implemented Interfaces:
Runnable, Sender<ByteBuffer>

public final class IoSender
extends Object
implements Runnable, Sender<ByteBuffer>


Constructor Summary
IoSender(IoContext ioCtx, int bufferSize, long timeout)
           
 
Method Summary
 void close()
           
(package private)  void close(boolean reportException)
           
 void flush()
           
 void run()
           
 void send(ByteBuffer buf)
           
 void setIdleTimeout(int i)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IoSender

public IoSender(IoContext ioCtx,
                int bufferSize,
                long timeout)
Method Detail

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