io.micronaut.pulsar

Interface PulsarProducerRegistry

All Known Implementing Classes:

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(java.lang.String id) Get single managed producer by its name.
java.util.Set<java.lang.String>	getProducerIds() Get all managed producer identifiers.
java.util.Map<java.lang.String,org.apache.pulsar.client.api.Producer<?>>	getProducers() Get all managed producers.

Method Detail

getProducers

java.util.Map<java.lang.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
                                                     java.lang.String id)

Get single managed producer by its name.

Parameters:

id - unique identifier

Returns:

Pulsar producer by given name

getProducerIds

java.util.Set<java.lang.String> getProducerIds()

Get all managed producer identifiers.

Returns:

List of producer names representing their identifiers in registry.