Class PulsarMessagingMessageListenerAdapter<V>
java.lang.Object
org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter<V>
- Type Parameters:
V- payload type.
- Direct Known Subclasses:
PulsarBatchMessagingMessageListenerAdapter,PulsarReactiveMessagingMessageListenerAdapter,PulsarRecordMessagingMessageListenerAdapter,PulsarRecordMessagingMessageListenerAdapter
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 PulsarRecordMessageConverter<V>protected TypegetType()protected final ObjectinvokeHandler(Object data, Message<?> message, org.apache.pulsar.client.api.Consumer<V> consumer, Acknowledgement acknowledgement) 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(PulsarRecordMessageConverter<V> messageConverter) voidsetMessagingConverter(SmartMessageConverter messageConverter) protected Message<?>toMessagingMessage(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Consumer<V> consumer)
-
Field Details
-
logger
-
-
Constructor Details
-
PulsarMessagingMessageListenerAdapter
-
-
Method Details
-
setMessageConverter
-
getMessageConverter
-
setMessagingConverter
-
getType
-
setFallbackType
-
setHandlerMethod
-
isPulsarMessageList
protected boolean isPulsarMessageList() -
setBeanResolver
-
isMessageList
protected boolean isMessageList() -
isSpringMessageFlux
protected boolean isSpringMessageFlux() -
toMessagingMessage
-
invokeHandler
protected final Object invokeHandler(Object data, Message<?> message, org.apache.pulsar.client.api.Consumer<V> consumer, Acknowledgement acknowledgement) -
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()
-