PulsarConsumerRegistry (pulsar-parent 2.2.0 API)

All Known Implementing Classes:: PulsarConsumerProcessor

public interface PulsarConsumerRegistry

A registry for created Pulsar consumers.

Since:: 1.0
Author:: Haris Secic

Method Summary

Modifier and Type

Method

Description

boolean

consumerExists(@NonNull String id)

<T> org.apache.pulsar.client.api.Consumer<T>

getConsumer(@NonNull String id)

Set<String>

getConsumerIds()

Map<String,org.apache.pulsar.client.api.Consumer<?>>

getConsumers()

boolean

isPaused(@NonNull String id)

void

pause(@NonNull String id)

void

resume(@NonNull String id)

Method Details
- getConsumers
  
  Map<String,org.apache.pulsar.client.api.Consumer<?>> getConsumers()
- getConsumer
  
  <T> org.apache.pulsar.client.api.Consumer<T> getConsumer(@NonNull @NonNull String id)
- consumerExists
  
  boolean consumerExists(@NonNull @NonNull String id)
- getConsumerIds
  
  Set<String> getConsumerIds()
- isPaused
  
  boolean isPaused(@NonNull @NonNull String id)
- pause
  
  void pause(@NonNull @NonNull String id)
- resume
  
  void resume(@NonNull @NonNull String id)