io.micronaut.pulsar

Interface PulsarConsumerRegistry

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 and Description
<T> org.apache.pulsar.client.api.Consumer<T>	getConsumer(java.lang.String id)
java.util.Set<java.lang.String>	getConsumerIds()
java.util.Map<java.lang.String,org.apache.pulsar.client.api.Consumer<?>>	getConsumers()
boolean	isPaused(java.lang.String id)
void	pause(java.lang.String id)
void	resume(java.lang.String id)

Method Detail

getConsumers

java.util.Map<java.lang.String,org.apache.pulsar.client.api.Consumer<?>> getConsumers()

getConsumer

<T> org.apache.pulsar.client.api.Consumer<T> getConsumer(@NonNull
                                                         java.lang.String id)

getConsumerIds

java.util.Set<java.lang.String> getConsumerIds()

isPaused

boolean isPaused(@NonNull
                 java.lang.String id)

pause

void pause(@NonNull
           java.lang.String id)

resume

void resume(@NonNull
            java.lang.String id)