Interface ReactivePulsarConsumerFactory<T>
- Type Parameters:
T- payload type for the consumer.
- All Known Implementing Classes:
DefaultReactivePulsarConsumerFactory
public interface ReactivePulsarConsumerFactory<T>
Pulsar reactive consumer factory interface.
- Author:
- Christophe Bornet
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>createConsumer(org.apache.pulsar.client.api.Schema<T> schema) Create a reactive message consumer.org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers) Create a reactive message consumer.
-
Method Details
-
createConsumer
org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema) Create a reactive message consumer.- Parameters:
schema- the schema of the messages to be consumed- Returns:
- the reactive message consumer
-
createConsumer
org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers) Create a reactive message consumer.- Parameters:
schema- the schema of the messages to be consumedcustomizers- the optional list of customizers to apply to the reactive message consumer builder- Returns:
- the reactive message consumer
-