public interface PulsarConsumerRegistry
Modifier and Type | Method and Description |
---|---|
boolean |
consumerExists(String id) |
<T> org.apache.pulsar.client.api.Consumer<T> |
getConsumer(String id) |
Set<String> |
getConsumerIds() |
Map<String,org.apache.pulsar.client.api.Consumer<?>> |
getConsumers() |
boolean |
isPaused(String id) |
void |
pause(String id) |
void |
resume(String id) |