org.apache.avro.ipc
Class SocketTransceiver

java.lang.Object
  extended by org.apache.avro.ipc.Transceiver
      extended by 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


Copyright © 2010 The Apache Software Foundation