Class PulsarReactiveStreamingMessagingMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter<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
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter
logger -
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<org.apache.pulsar.reactive.client.api.MessageResult<Void>>Callback passed toReactiveMessagePipelineBuilder.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, isMultipleMessageTypeMethods inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecords, isHeaderFound, isMessageList, isPulsarMessageList, isSimpleExtraction, isSpringMessage, isSpringMessageFlux, parameterIsType, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, toMessagingMessage
-
Constructor Details
-
PulsarReactiveStreamingMessagingMessageListenerAdapter
-
-
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:ReactivePulsarStreamingHandlerCallback passed toReactiveMessagePipelineBuilder.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:
receivedin interfaceReactivePulsarStreamingHandler<V>- Parameters:
records- the messages received- Returns:
- a completed
Publisherwhen the callback is done.
-