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 and Description
org.apache.pulsar.client.api.Producer<?>	getProducer(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 Detail

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
                                                     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.