public class PulsarMessageListenerImpl
extends java.lang.Object
implements org.apache.pulsar.client.api.MessageListener<byte[]>
构造器和说明 |
---|
PulsarMessageListenerImpl(CloudProps cloudProps,
CloudEventObserverManger observerManger) |
限定符和类型 | 方法和说明 |
---|---|
void |
reachedEndOfTopic(org.apache.pulsar.client.api.Consumer<byte[]> consumer) |
void |
received(org.apache.pulsar.client.api.Consumer<byte[]> consumer,
org.apache.pulsar.client.api.Message<byte[]> msg) |
public PulsarMessageListenerImpl(CloudProps cloudProps, CloudEventObserverManger observerManger)
public void received(org.apache.pulsar.client.api.Consumer<byte[]> consumer, org.apache.pulsar.client.api.Message<byte[]> msg)
received
在接口中 org.apache.pulsar.client.api.MessageListener<byte[]>
public void reachedEndOfTopic(org.apache.pulsar.client.api.Consumer<byte[]> consumer)
reachedEndOfTopic
在接口中 org.apache.pulsar.client.api.MessageListener<byte[]>