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
-