io.micronaut.pulsar

Interface PulsarReaderRegistry

All Known Implementing Classes:

PulsarReaderFactory

public interface PulsarReaderRegistry

Keeps track of all created Pulsar readers.

Since:

1.0

Author:

Haris Secic

Method Summary

Modifier and Type	Method and Description
org.apache.pulsar.client.api.Reader<?>	getReader(java.lang.String identifier) If not specified explicitly, reader name will default to property/field name.
java.util.Collection<org.apache.pulsar.client.api.Reader<?>>	getReaders()

Method Detail

getReader

org.apache.pulsar.client.api.Reader<?> getReader(java.lang.String identifier)

If not specified explicitly, reader name will default to property/field name.

Parameters:

identifier - unique identifier for a reader

Returns:

Pulsar Reader if found for a given name

getReaders

java.util.Collection<org.apache.pulsar.client.api.Reader<?>> getReaders()

Returns:

all registered Pulsar Readers