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
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected TypedetermineInferredType(Method method) protected final PulsarMessageConverter<V>protected TypegetType()protected final ObjectinvokeHandler(Message<?> message, Object... providedArgs) booleanprotected booleanDetermine if the type is a reactive Flux.booleanprotected booleanprotected booleanisMultipleMessageType(Type type) Determines if a type is one that holds multiple messages.protected booleanbooleanbooleanprotected booleanprotected booleanparameterIsType(Type parameterType, Type type) voidsetBeanResolver(BeanResolver beanResolver) voidsetFallbackType(Class<?> fallbackType) voidsetHandlerMethod(HandlerAdapter handlerMethod) voidsetMessageConverter(PulsarMessageConverter<V> messageConverter) voidsetMessagingConverter(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
Listor 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()
-