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