Class AbstractPulsarMessageToSpringMessageAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter<V>
- Type Parameters:
V
- payload type.
- Direct Known Subclasses:
PulsarBatchMessagesToSpringMessageListenerAdapter
,PulsarReactiveMessagingMessageListenerAdapter
,PulsarRecordMessageToSpringMessageListenerAdapter
,PulsarRecordMessageToSpringMessageReaderAdapter
An abstract
MessageListener
adapter providing the
necessary infrastructure to extract the payload from a Pulsar message.- Author:
- Soby Chacko, Christophe Bornet
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected Type
determineInferredType
(Method method) protected final PulsarMessageConverter<V>
protected Type
getType()
protected final Object
invokeHandler
(Message<?> message, Object... providedArgs) boolean
protected boolean
Determine if the type is a reactive Flux.boolean
protected boolean
protected boolean
isMultipleMessageType
(Type type) Determines if a type is one that holds multiple messages.protected boolean
boolean
boolean
protected boolean
protected boolean
parameterIsType
(Type parameterType, Type type) void
setBeanResolver
(BeanResolver beanResolver) void
setFallbackType
(Class<?> fallbackType) void
setHandlerMethod
(HandlerAdapter handlerMethod) void
setMessageConverter
(PulsarMessageConverter<V> messageConverter) void
setMessagingConverter
(SmartMessageConverter messageConverter) protected Message<?>
toMessagingMessage
(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Consumer<V> consumer) protected Message<?>
toMessagingMessageFromReader
(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Reader<V> reader)
-
Field Details
-
logger
-
-
Constructor Details
-
AbstractPulsarMessageToSpringMessageAdapter
-
-
Method Details
-
setMessageConverter
-
getMessageConverter
-
setMessagingConverter
-
getType
-
setFallbackType
-
setHandlerMethod
-
isPulsarMessageList
protected boolean isPulsarMessageList() -
setBeanResolver
-
isMessageList
protected boolean isMessageList() -
isSpringMessageFlux
protected boolean isSpringMessageFlux() -
toMessagingMessage
-
toMessagingMessageFromReader
-
invokeHandler
-
determineInferredType
-
isMultipleMessageType
Determines if a type is one that holds multiple messages.- Parameters:
type
- the type to check- Returns:
- true if the type is a
List
or aMessages
, false otherwise
-
isFlux
Determine if the type is a reactive Flux.- Parameters:
type
- type to check- Returns:
- false as the imperative side does not know about Flux
-
parameterIsType
-
isSimpleExtraction
public boolean isSimpleExtraction() -
isConsumerRecords
public boolean isConsumerRecords() -
isHeaderFound
public boolean isHeaderFound() -
isSpringMessage
public boolean isSpringMessage()
-