public class AvroListener extends Object
Constructor and Description |
---|
AvroListener(AvroEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
register(String messageName,
AvroConsumer consumer)
Registers consumer by appropriate message name as key in registry.
|
Object |
respond(org.apache.avro.Protocol.Message message,
Object request,
org.apache.avro.specific.SpecificData data) |
boolean |
unregister(String messageName)
Unregisters consumer by message name.
|
public AvroListener(AvroEndpoint endpoint) throws Exception
Exception
public void register(String messageName, AvroConsumer consumer) throws AvroComponentException
messageName
- message nameconsumer
- avro consumerAvroComponentException
public boolean unregister(String messageName)
messageName
- message nameApache Camel