Package io.micronaut.pulsar

Interface PulsarProducerRegistry

All Known Implementing Classes:
PulsarMultitenantProducerAdvice, PulsarProducerAdvice
public interface PulsarProducerRegistry
A registry of managed Producer instances key by id and type.
Since:
1.0
Author:
Haris Secic

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pulsar.client.api.Producer<?>
    getProducer(@NonNull String id)
    Get single managed producer by its name.
    Set<String>
    getProducerIds()
    Get all managed producer identifiers.
    Map<String,org.apache.pulsar.client.api.Producer<?>>
    getProducers()
    Get all managed producers.

  • Method Details

    • getProducers

      Map<String,org.apache.pulsar.client.api.Producer<?>> getProducers()
      Get all managed producers.
      Returns:
      List of managed producers.

    • getProducer

      org.apache.pulsar.client.api.Producer<?> getProducer(@NonNull @NonNull String id)
      Get single managed producer by its name.
      Parameters:
      id - unique identifier
      Returns:
      Pulsar producer by given name

    • getProducerIds

      Set<String> getProducerIds()
      Get all managed producer identifiers.
      Returns:
      List of producer names representing their identifiers in registry.