org.apache.avro.ipc
Class LocalTransceiver

java.lang.Object
  extended by org.apache.avro.ipc.Transceiver
      extended by org.apache.avro.ipc.LocalTransceiver
All Implemented Interfaces:
Closeable

public class LocalTransceiver
extends Transceiver

Implementation of IPC that remains in process.


Constructor Summary
LocalTransceiver(Responder responder)
           
 
Method Summary
 String getRemoteName()
           
 List<ByteBuffer> readBuffers()
           
 List<ByteBuffer> transceive(List<ByteBuffer> request)
           
 void writeBuffers(List<ByteBuffer> buffers)
           
 
Methods inherited from class org.apache.avro.ipc.Transceiver
close
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LocalTransceiver

public LocalTransceiver(Responder responder)
Method Detail

getRemoteName

public String getRemoteName()
Specified by:
getRemoteName in class Transceiver

transceive

public List<ByteBuffer> transceive(List<ByteBuffer> request)
                            throws IOException
Overrides:
transceive in class Transceiver
Throws:
IOException

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


Copyright © 2010 The Apache Software Foundation