Package 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
    Description
    org.apache.pulsar.client.api.Reader<?>
    getReader(String identifier)
    If not specified explicitly, reader name will default to property/field name.
    Collection<org.apache.pulsar.client.api.Reader<?>>
    getReaders()
     

  • Method Details

    • getReader

      org.apache.pulsar.client.api.Reader<?> getReader(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

      Collection<org.apache.pulsar.client.api.Reader<?>> getReaders()
      Returns:
      all registered Pulsar Readers