Class PulsarReactiveMessagingMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter<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 PulsarMessagingMessageListenerAdapter<V>
An abstract base for
MessageListener adapters.- Author:
- Chris Bono
-
Field Summary
Fields inherited from class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter
logger -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected booleanDetermine if the type is a reactive Flux.protected booleanisMultipleMessageType(Type type) Determines if a type is one that holds multiple messages.Methods 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
-
PulsarReactiveMessagingMessageListenerAdapter
-
-
Method Details
-
isMultipleMessageType
Determines if a type is one that holds multiple messages.- Overrides:
isMultipleMessageTypein classPulsarMessagingMessageListenerAdapter<V>- Parameters:
type- the type to check- Returns:
- true if the type is a
List,MessagesorFlux, false otherwise
-
isFlux
Determine if the type is a reactive Flux.- Overrides:
isFluxin classPulsarMessagingMessageListenerAdapter<V>- Parameters:
type- type to check- Returns:
- true if the type is a reactive Flux, false otherwise
-