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

Class PulsarReactiveOneByOneMessagingMessageListenerAdapter<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.PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>

Type Parameters:

V - payload type.

All Implemented Interfaces:

ReactivePulsarMessageHandler, ReactivePulsarOneByOneMessageHandler<V>

public class PulsarReactiveOneByOneMessagingMessageListenerAdapter<V>
extends PulsarReactiveMessagingMessageListenerAdapter<V>
implements ReactivePulsarOneByOneMessageHandler<V>

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

Author:

Christophe Bornet, Soby Chacko

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
PulsarReactiveOneByOneMessagingMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
org.reactivestreams.Publisher<Void>	received(org.apache.pulsar.client.api.Message<V> record)	Callback passed to ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>) that will be called for each 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

PulsarReactiveOneByOneMessagingMessageListenerAdapter

public PulsarReactiveOneByOneMessagingMessageListenerAdapter(Object bean,
 Method method)

Method Details

received

public org.reactivestreams.Publisher<Void> received(org.apache.pulsar.client.api.Message<V> record)

Description copied from interface: ReactivePulsarOneByOneMessageHandler

Callback passed to ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>) that will be called for each received message.

Specified by:

received in interface ReactivePulsarOneByOneMessageHandler<V>

Parameters:

record - the message received

Returns:

a completed Publisher when the callback is done.