Class DefaultReactivePulsarReaderFactory<T>
java.lang.Object
org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory<T>
- Type Parameters:
T
- underlying payload type for the reactive reader.
- All Implemented Interfaces:
ReactivePulsarReaderFactory<T>
public class DefaultReactivePulsarReaderFactory<T>
extends Object
implements ReactivePulsarReaderFactory<T>
Default implementation for
ReactivePulsarReaderFactory
.- Author:
- Christophe Bornet
-
Constructor Summary
ConstructorDescriptionDefaultReactivePulsarReaderFactory
(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec readerSpec) -
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.
-
Constructor Details
-
DefaultReactivePulsarReaderFactory
public DefaultReactivePulsarReaderFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec readerSpec)
-
-
Method Details
-
createReader
public org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema) Description copied from interface:ReactivePulsarReaderFactory
Create a reactive message reader.- Specified by:
createReader
in interfaceReactivePulsarReaderFactory<T>
- Parameters:
schema
- the schema of the messages to be read- Returns:
- the reactive message reader
-
createReader
public org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers) Description copied from interface:ReactivePulsarReaderFactory
Create a reactive message reader.- Specified by:
createReader
in interfaceReactivePulsarReaderFactory<T>
- 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
-