public abstract class GenericResponder extends Responder
Responder implementation for generic Java data.rpcMetaPlugins| Constructor and Description |
|---|
GenericResponder(Protocol local) |
| Modifier and Type | Method and Description |
|---|---|
protected DatumReader<Object> |
getDatumReader(Schema actual,
Schema expected) |
protected DatumWriter<Object> |
getDatumWriter(Schema schema) |
Object |
readRequest(Schema actual,
Schema expected,
Decoder in)
Reads a request 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.
|
public GenericResponder(Protocol local)
protected DatumWriter<Object> getDatumWriter(Schema schema)
protected DatumReader<Object> getDatumReader(Schema actual, Schema expected)
public Object readRequest(Schema actual, Schema expected, Decoder in) throws IOException
ResponderreadRequest in class ResponderIOExceptionpublic void writeResponse(Schema schema, Object response, Encoder out) throws IOException
ResponderwriteResponse in class ResponderIOExceptionpublic void writeError(Schema schema, Object error, Encoder out) throws IOException
ResponderwriteError in class ResponderIOExceptionCopyright © 2009-2012 The Apache Software Foundation. All Rights Reserved.