org.apache.avro.ipc
Class SocketTransceiver

java.lang.Object
  org.apache.avro.ipc.Transceiver
      org.apache.avro.ipc.SocketTransceiver

All Implemented Interfaces:

Closeable

public class SocketTransceiver
extends Transceiver

A socket-based Transceiver implementation. This uses a simple, non-standard wire protocol and is not intended for production services.

Constructor Summary

SocketTransceiver(SocketAddress address)

SocketTransceiver(SocketChannel channel)

Method Summary

void	close()
String	getRemoteName()
List<ByteBuffer>	readBuffers()
void	writeBuffers(List<ByteBuffer> buffers)

Methods inherited from class org.apache.avro.ipc.Transceiver

transceive

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketTransceiver

public SocketTransceiver(SocketAddress address)
                  throws IOException

Throws:

IOException

SocketTransceiver

public SocketTransceiver(SocketChannel channel)
                  throws IOException

Throws:

IOException

Method Detail

getRemoteName

public String getRemoteName()

Specified by:

getRemoteName in class Transceiver

readBuffers

public List<ByteBuffer> readBuffers()
                             throws IOException

Specified by:

readBuffers in class Transceiver

Throws:

IOException

writeBuffers

public void writeBuffers(List<ByteBuffer> buffers)
                  throws IOException

Specified by:

writeBuffers in class Transceiver

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Overrides:

close in class Transceiver

Throws:

IOException