org.apache.pulsar.client.api

Interface ConsumerEventListener

All Superinterfaces:

Serializable

public interface ConsumerEventListener
extends Serializable

Listener on the consumer state changes.

Method Summary

Modifier and Type	Method and Description
void	becameActive(Consumer<?> consumer, int partitionId) Notified when the consumer group is changed, and the consumer becomes the active consumer.
void	becameInactive(Consumer<?> consumer, int partitionId) Notified when the consumer group is changed, and the consumer is still inactive or becomes inactive.

Method Detail

becameActive

void becameActive(Consumer<?> consumer,
                  int partitionId)

Notified when the consumer group is changed, and the consumer becomes the active consumer.

becameInactive

void becameInactive(Consumer<?> consumer,
                    int partitionId)

Notified when the consumer group is changed, and the consumer is still inactive or becomes inactive.