Package org.springframework.pulsar.reactive.listener.adapter

Class PulsarReactiveStreamingMessagingMessageListenerAdapter<V>

java.lang.Object

org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>

org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter<V>

org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveStreamingMessagingMessageListenerAdapter<V>

Type Parameters:

V - payload type.

All Implemented Interfaces:

ReactivePulsarMessageHandler, ReactivePulsarStreamingHandler<V>

public class PulsarReactiveStreamingMessagingMessageListenerAdapter<V>
extends PulsarReactiveMessagingMessageListenerAdapter<V>
implements ReactivePulsarStreamingHandler<V>

A MessageListener adapter that invokes a configurable HandlerAdapter; used when the factory is configured for the listener to receive a flux of messages.

Author:

Christophe Bornet, Soby Chacko

Field Summary

Fields inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

logger

Constructor Summary

Constructors

Constructor	Description
PulsarReactiveStreamingMessagingMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<org.apache.pulsar.reactive.client.api.MessageResult<Void>>	received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<V>> records)	Callback passed to ReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>) that will be applied to the flux of received message.

Methods inherited from class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveMessagingMessageListenerAdapter

isFlux, isMultipleMessageType

Methods inherited from class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isHeaderFound, isMessageList, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessage, toMessagingMessageFromReader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PulsarReactiveStreamingMessagingMessageListenerAdapter

public PulsarReactiveStreamingMessagingMessageListenerAdapter(Object bean,
 Method method)

Method Details

received

public reactor.core.publisher.Flux<org.apache.pulsar.reactive.client.api.MessageResult<Void>> received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<V>> records)

Description copied from interface: ReactivePulsarStreamingHandler

Callback passed to ReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>) that will be applied to the flux of received message.

Specified by:

received in interface ReactivePulsarStreamingHandler<V>

Parameters:

records - the messages received

Returns:

a completed Publisher when the callback is done.