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

Class PulsarReactiveMessagingMessageListenerAdapter<V>

java.lang.Object

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

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

Type Parameters:

V - payload type.

Direct Known Subclasses:

PulsarReactiveOneByOneMessagingMessageListenerAdapter, PulsarReactiveStreamingMessagingMessageListenerAdapter

public abstract class PulsarReactiveMessagingMessageListenerAdapter<V>
extends AbstractPulsarMessageToSpringMessageAdapter<V>

An abstract base for MessageListener adapters.

Author:

Chris Bono

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
PulsarReactiveMessagingMessageListenerAdapter(Object bean, Method method)

Method Summary

Modifier and Type	Method	Description
protected boolean	isFlux(Type type)	Determine if the type is a reactive Flux.
protected boolean	isMultipleMessageType(Type type)	Determines if a type is one that holds multiple messages.

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

PulsarReactiveMessagingMessageListenerAdapter

public PulsarReactiveMessagingMessageListenerAdapter(Object bean,
 Method method)

Method Details

isMultipleMessageType

protected boolean isMultipleMessageType(Type type)

Determines if a type is one that holds multiple messages.

Overrides:

isMultipleMessageType in class AbstractPulsarMessageToSpringMessageAdapter<V>

Parameters:

type - the type to check

Returns:

true if the type is a List, Messages or Flux, false otherwise

isFlux

protected boolean isFlux(Type type)

Determine if the type is a reactive Flux.

Overrides:

isFlux in class AbstractPulsarMessageToSpringMessageAdapter<V>

Parameters:

type - type to check

Returns:

true if the type is a reactive Flux, false otherwise