Package io.micronaut.pulsar.processor

Class DefaultListener

java.lang.Object

io.micronaut.pulsar.processor.DefaultListener

All Implemented Interfaces:

MessageListenerResolver, Serializable, org.apache.pulsar.client.api.MessageListener

public class DefaultListener
extends Object
implements MessageListenerResolver

Default listener for incoming Pulsar messages.

Since:

1.0

Author:

Haris Secic

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultListener(io.micronaut.inject.ExecutableMethod method, boolean useMessageWrapper, Object invoker, PulsarArgumentHandler argumentHandler)

Method Summary

Modifier and Type	Method	Description
void	received(org.apache.pulsar.client.api.Consumer consumer, org.apache.pulsar.client.api.Message msg)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pulsar.client.api.MessageListener

reachedEndOfTopic

Constructor Details

DefaultListener

public DefaultListener(io.micronaut.inject.ExecutableMethod method,
 boolean useMessageWrapper,
 Object invoker,
 PulsarArgumentHandler argumentHandler)

Method Details

received

public void received(org.apache.pulsar.client.api.Consumer consumer,
 org.apache.pulsar.client.api.Message msg)

Specified by:

received in interface org.apache.pulsar.client.api.MessageListener