org.apache.avro.ipc
Class Requestor

java.lang.Object
  org.apache.avro.ipc.Requestor

Direct Known Subclasses:

GenericRequestor, ReflectRequestor

public abstract class Requestor
extends Object

Base class for the client side of a protocol interaction.

Constructor Summary

protected

Requestor(Protocol local, Transceiver transceiver)

Method Summary

Protocol	getLocal()
Protocol	getRemote()
Transceiver	getTransceiver()
abstract AvroRemoteException	readError(Schema schema, Decoder in) Reads an error message.
abstract Object	readResponse(Schema schema, Decoder in) Reads a response message.
Object	request(String messageName, Object request) Writes a request message and reads a response or error message.
abstract void	writeRequest(Schema schema, Object request, Encoder out) Writes a request message.

Methods inherited from class java.lang.Object

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

Constructor Detail

Requestor

protected Requestor(Protocol local,
                    Transceiver transceiver)
             throws IOException

Throws:

IOException

Method Detail

getLocal

public Protocol getLocal()

getRemote

public Protocol getRemote()

getTransceiver

public Transceiver getTransceiver()

request

public Object request(String messageName,
                      Object request)
               throws IOException

Writes a request message and reads a response or error message.

Throws:

IOException

writeRequest

public abstract void writeRequest(Schema schema,
                                  Object request,
                                  Encoder out)
                           throws IOException

Writes a request message.

Throws:

IOException

readResponse

public abstract Object readResponse(Schema schema,
                                    Decoder in)
                             throws IOException

Reads a response message.

Throws:

IOException

readError

public abstract AvroRemoteException readError(Schema schema,
                                              Decoder in)
                                       throws IOException

Reads an error message.

Throws:

IOException