Package org.springframework.rabbit.stream.listener.adapter

Class StreamMessageListenerAdapter

java.lang.Object

org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

org.springframework.rabbit.stream.listener.adapter.StreamMessageListenerAdapter

All Implemented Interfaces:

MessageListener, ChannelAwareMessageListener, StreamMessageListener

public class StreamMessageListenerAdapter
extends MessagingMessageListenerAdapter
implements StreamMessageListener

A listener adapter that receives native stream messages.

Since:

2.4

Author:

Gary Russell, Artem Bilan

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

errorHandler, messagingMessageConverter, returnExceptions

Fields inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

logger

Constructor Summary

Constructors

Constructor	Description
StreamMessageListenerAdapter(@Nullable Object bean, @Nullable Method method, boolean returnExceptions, @Nullable RabbitListenerErrorHandler errorHandler)	Construct an instance with the provided arguments.

Method Summary

Modifier and Type	Method	Description
protected MessagingMessageConverterAdapter	newMessagingMessageConverterAdapter(@Nullable Object bean, @Nullable Method method, boolean batch)	Create a new MessagingMessageConverterAdapter instance based on the given bean and method.
void	onStreamMessage(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context)	Process a message.

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter

asyncFailure, buildMessage, getHandlerAdapter, getMessagingMessageConverter, handleException, invokeHandler, invokeHandlerAndProcessResult, isAsyncReplies, onMessage, setAcknowledgeOnError, setHandlerAdapter, setHeaderMapper, setMessageConverter, toMessagingMessage

Methods inherited from class org.springframework.amqp.rabbit.listener.adapter.AbstractAdaptableMessageListener

basicAck, containerAckMode, convert, doHandleResult, doPublish, extractMessage, getBeforeSendReplyPostProcessors, getEncoding, getMessageConverter, getReceivedExchange, getReplyContentType, getReplyToAddress, handleListenerException, handleResult, handleResult, isConverterWinsContentType, isDefaultRequeueRejected, isManualAck, postProcessChannel, postProcessResponse, sendResponse, setBeanResolver, setBeforeSendReplyPostProcessors, setConverterWinsContentType, setDefaultRequeueRejected, setEncoding, setMandatoryPublish, setRecoveryCallback, setReplyContentType, setReplyPostProcessor, setResponseAddress, setResponseExchange, setResponseRoutingKey, setRetryTemplate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener

onMessage, onMessageBatch

Methods inherited from interface org.springframework.amqp.core.MessageListener

containerAckMode, isAsyncReplies, onMessageBatch

Constructor Details

StreamMessageListenerAdapter

public StreamMessageListenerAdapter(@Nullable Object bean,
 @Nullable Method method,
 boolean returnExceptions,
 @Nullable RabbitListenerErrorHandler errorHandler)

Construct an instance with the provided arguments.

Parameters:

bean - the bean.

method - the method.

returnExceptions - true to return exceptions.

errorHandler - the error handler.

Method Details

newMessagingMessageConverterAdapter

protected MessagingMessageConverterAdapter newMessagingMessageConverterAdapter(@Nullable Object bean,
 @Nullable Method method,
 boolean batch)

Description copied from class: MessagingMessageListenerAdapter

Create a new MessagingMessageConverterAdapter instance based on the given bean and method. By default, additional provided argument type is a Channel. Extensions of this class can override this method to provide some other eligible additional argument types not required conversion.

Overrides:

newMessagingMessageConverterAdapter in class MessagingMessageListenerAdapter

Parameters:

bean - the bean of the method.

method - the method to infer a payload type.

batch - if the method is a batch listener.

Returns:

the MessagingMessageConverterAdapter instance.

onStreamMessage

public void onStreamMessage(com.rabbitmq.stream.Message message,
 com.rabbitmq.stream.MessageHandler.Context context)

Description copied from interface: StreamMessageListener

Process a message.

Specified by:

onStreamMessage in interface StreamMessageListener

Parameters:

message - the message.

context - the stream context.