Class DefaultReactivePulsarConsumerFactory<T>
java.lang.Object
org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory<T>
- Type Parameters:
T
- underlying payload type for the reactive consumer.
- All Implemented Interfaces:
ReactivePulsarConsumerFactory<T>
public class DefaultReactivePulsarConsumerFactory<T>
extends Object
implements ReactivePulsarConsumerFactory<T>
Default implementation for
ReactivePulsarConsumerFactory
.- Author:
- Christophe Bornet
-
Constructor Summary
ConstructorDescriptionDefaultReactivePulsarConsumerFactory
(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec consumerSpec) -
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.
-
Constructor Details
-
DefaultReactivePulsarConsumerFactory
public DefaultReactivePulsarConsumerFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec consumerSpec)
-
-
Method Details
-
createConsumer
public org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema) Description copied from interface:ReactivePulsarConsumerFactory
Create a reactive message consumer.- Specified by:
createConsumer
in interfaceReactivePulsarConsumerFactory<T>
- Parameters:
schema
- the schema of the messages to be consumed- Returns:
- the reactive message consumer
-
createConsumer
public org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers) Description copied from interface:ReactivePulsarConsumerFactory
Create a reactive message consumer.- Specified by:
createConsumer
in interfaceReactivePulsarConsumerFactory<T>
- 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
-