org.apache.avro.specific
Class SpecificResponder

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

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