org.apache.camel.component.avro
Class AvroSpecificResponder

java.lang.Object
  org.apache.avro.ipc.Responder
      org.apache.avro.ipc.generic.GenericResponder
          org.apache.avro.ipc.specific.SpecificResponder
              org.apache.camel.component.avro.AvroSpecificResponder

public class AvroSpecificResponder
extends org.apache.avro.ipc.specific.SpecificResponder

Field Summary

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

rpcMetaPlugins

Constructor Summary

AvroSpecificResponder(org.apache.avro.Protocol protocol, AvroListener listener)

Method Summary

Object

respond(org.apache.avro.Protocol.Message message, Object request)

Methods inherited from class org.apache.avro.ipc.specific.SpecificResponder

getDatumReader, getDatumWriter, getSpecificData, writeError

Methods inherited from class org.apache.avro.ipc.generic.GenericResponder

getGenericData, readRequest, writeResponse

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

addRPCPlugin, getLocal, getRemote, respond, respond

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroSpecificResponder

public AvroSpecificResponder(org.apache.avro.Protocol protocol,
                             AvroListener listener)
                      throws Exception

Throws:

Exception

Method Detail

respond

public Object respond(org.apache.avro.Protocol.Message message,
                      Object request)
               throws Exception

Overrides:

respond in class org.apache.avro.ipc.specific.SpecificResponder

Throws:

Exception