Class AvroListener


  • public class AvroListener
    extends Object
    This class holds server that listen to given protocol:host:port combination and dispatches messages to different routes mapped.
    • Method Detail

      • unregister

        public boolean unregister​(String messageName)
        Unregisters consumer by message name. Stops server in case if all consumers are unregistered and default consumer is absent or stopped.
        Parameters:
        messageName - message name
        Returns:
        true if all consumers are unregistered and defaultConsumer is absent or null. It means that this responder can be unregistered.
      • respond

        public Object respond​(org.apache.avro.Protocol.Message message,
                              Object request,
                              org.apache.avro.specific.SpecificData data)
                       throws Exception
        Throws:
        Exception