public final class IoSender extends Object implements Runnable, ByteBufferSender
Constructor and Description |
---|
IoSender(Socket socket,
int bufferSize,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
flush() |
void |
initiate() |
void |
run() |
void |
send(QpidByteBuffer buf) |
void |
setReceiver(org.apache.qpid.transport.network.io.IoReceiver receiver) |
public IoSender(Socket socket, int bufferSize, long timeout)
public void initiate()
public void send(QpidByteBuffer buf)
send
in interface ByteBufferSender
public void flush()
flush
in interface ByteBufferSender
public void close()
close
in interface ByteBufferSender
public void setReceiver(org.apache.qpid.transport.network.io.IoReceiver receiver)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.