Package io.micronaut.pulsar.events

Class ConsumerSubscribedEvent

java.lang.Object

io.micronaut.pulsar.events.ConsumerSubscribedEvent

public final class ConsumerSubscribedEvent
extends Object

Produced when Pulsar consumer connects to a broker and starts listening to specified topics.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor	Description
ConsumerSubscribedEvent(org.apache.pulsar.client.api.Consumer<?> consumer)

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.Consumer<?>	getConsumer()

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerSubscribedEvent

public ConsumerSubscribedEvent(org.apache.pulsar.client.api.Consumer<?> consumer)

Method Details

getConsumer

public org.apache.pulsar.client.api.Consumer<?> getConsumer()