org.apache.avro.specific
Class SpecificResponder

java.lang.Object
  extended by org.apache.avro.ipc.Responder
      extended by org.apache.avro.specific.SpecificResponder
Direct Known Subclasses:
ReflectResponder

public class SpecificResponder
extends Responder

Responder for generated interfaces.


Field Summary
 
Fields inherited from class org.apache.avro.ipc.Responder
rpcMetaPlugins
 
Constructor Summary
  SpecificResponder(Class iface, Object impl)
           
  SpecificResponder(Protocol protocol, Object impl)
           
protected SpecificResponder(Protocol protocol, Object impl, SpecificData data)
           
 
Method Summary
protected  DatumReader<Object> getDatumReader(Schema schema)
           
protected  DatumWriter<Object> getDatumWriter(Schema schema)
           
 Object readRequest(Schema schema, Decoder in)
          Reads a request message.
 Object respond(Protocol.Message message, Object request)
          Computes the response for a message.
 void writeError(Schema schema, Object error, Encoder out)
          Writes an error message.
 void writeResponse(Schema schema, Object response, Encoder out)
          Writes a response message.
 
Methods inherited from class org.apache.avro.ipc.Responder
addRPCPlugin, getLocal, respond, respond
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SpecificResponder

public SpecificResponder(Class iface,
                         Object impl)

SpecificResponder

public SpecificResponder(Protocol protocol,
                         Object impl)

SpecificResponder

protected SpecificResponder(Protocol protocol,
                            Object impl,
                            SpecificData data)
Method Detail

getDatumWriter

protected DatumWriter<Object> getDatumWriter(Schema schema)

getDatumReader

protected DatumReader<Object> getDatumReader(Schema schema)

readRequest

public Object readRequest(Schema schema,
                          Decoder in)
                   throws IOException
Description copied from class: Responder
Reads a request message.

Specified by:
readRequest in class Responder
Throws:
IOException

writeResponse

public void writeResponse(Schema schema,
                          Object response,
                          Encoder out)
                   throws IOException
Description copied from class: Responder
Writes a response message.

Specified by:
writeResponse in class Responder
Throws:
IOException

writeError

public void writeError(Schema schema,
                       Object error,
                       Encoder out)
                throws IOException
Description copied from class: Responder
Writes an error message.

Specified by:
writeError in class Responder
Throws:
IOException

respond

public Object respond(Protocol.Message message,
                      Object request)
               throws Exception
Description copied from class: Responder
Computes the response for a message.

Specified by:
respond in class Responder
Throws:
Exception


Copyright © 2010 The Apache Software Foundation