org.apache.avro.generic
Class GenericRequestor

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

public class GenericRequestor
extends Requestor

Requestor implementation for generic Java data.

Field Summary

Fields inherited from class org.apache.avro.ipc.Requestor

rpcMetaPlugins

Constructor Summary

GenericRequestor(Protocol protocol, Transceiver transceiver)

Method Summary

AvroRemoteException	readError(Schema schema, Decoder in) Reads an error message.
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.
void	writeRequest(Schema schema, Object request, Encoder out) Writes a request message.

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

addRPCPlugin, getLocal, getRemote, getTransceiver

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericRequestor

public GenericRequestor(Protocol protocol,
                        Transceiver transceiver)
                 throws IOException

Throws:

IOException

Method Detail

request

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

Description copied from class: Requestor

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

Overrides:

request in class Requestor

Throws:

IOException

writeRequest

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

Description copied from class: Requestor

Writes a request message.

Specified by:

writeRequest in class Requestor

Throws:

IOException

readResponse

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

Description copied from class: Requestor

Reads a response message.

Specified by:

readResponse in class Requestor

Throws:

IOException

readError

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

Description copied from class: Requestor

Reads an error message.

Specified by:

readError in class Requestor

Throws:

IOException