Interface ReactivePulsarReaderFactory<T>
- Type Parameters:
T
- reactive message reader payload type
- All Known Implementing Classes:
DefaultReactivePulsarReaderFactory
public interface ReactivePulsarReaderFactory<T>
The strategy to create a
ReactiveMessageReader
instance(s).- Author:
- Christophe Bornet
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
createReader
(org.apache.pulsar.client.api.Schema<T> schema) Create a reactive message reader.org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
createReader
(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers) Create a reactive message reader.
-
Method Details
-
createReader
org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema) Create a reactive message reader.- Parameters:
schema
- the schema of the messages to be read- Returns:
- the reactive message reader
-
createReader
org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers) Create a reactive message reader.- Parameters:
schema
- the schema of the messages to be readcustomizers
- the optional list of readers to apply to the reactive message reader builder- Returns:
- the reactive message reader
-