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>

Constructor Summary

Constructors

Constructor and Description
IoSender(Socket socket, int bufferSize, long timeout)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	flush()
void	initiate()
void	run()
void	send(ByteBuffer buf)
void	setIdleTimeout(int i)
void	setReceiver(org.apache.qpid.transport.network.io.IoReceiver receiver)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IoSender

public IoSender(Socket socket,
        int bufferSize,
        long timeout)

Method Detail

initiate

public void initiate()

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>

run

public void run()

Specified by:

run in interface Runnable

setIdleTimeout

public void setIdleTimeout(int i)

Specified by:

setIdleTimeout in interface Sender<ByteBuffer>

setReceiver

public void setReceiver(org.apache.qpid.transport.network.io.IoReceiver receiver)