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
ConstructorsConstructorDescriptionDefaultReactivePulsarReaderFactory(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:ReactivePulsarReaderFactoryCreate a reactive message reader.- Specified by:
createReaderin 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:ReactivePulsarReaderFactoryCreate a reactive message reader.- Specified by:
createReaderin 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
-