Class DefaultStreamMessageConverter

java.lang.Object

org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter

All Implemented Interfaces:

MessageConverter, StreamMessageConverter

public class DefaultStreamMessageConverter
extends Object
implements StreamMessageConverter

Default StreamMessageConverter.

Since:

2.4

Author:

Gary Russell, Ngoc Nhan, Artem Bilan

Constructor Summary

Constructors

Constructor	Description
DefaultStreamMessageConverter()	Construct an instance using a WrapperMessageBuilder.
DefaultStreamMessageConverter(com.rabbitmq.stream.Codec codec)	Construct an instance using the provided codec.

Method Summary

Modifier and Type	Method	Description
com.rabbitmq.stream.Message	fromMessage(Message message)	Convert from a Message to a Java object.
void	setBuilderSupplier(Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)	Set a supplier for a message builder.
Message	toMessage(Object object, StreamMessageProperties messageProperties)

Methods inherited from class Object

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

Methods inherited from interface MessageConverter

toMessage

Methods inherited from interface StreamMessageConverter

toMessage

Constructor Details

DefaultStreamMessageConverter

public DefaultStreamMessageConverter()

Construct an instance using a WrapperMessageBuilder.

DefaultStreamMessageConverter

public DefaultStreamMessageConverter(com.rabbitmq.stream.Codec codec)

Construct an instance using the provided codec.

Parameters:

codec - the codec.

Method Details

setBuilderSupplier

public void setBuilderSupplier(Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)

Set a supplier for a message builder.

Parameters:

builderSupplier - the supplier.

toMessage

public Message toMessage(Object object,
 StreamMessageProperties messageProperties)
                  throws MessageConversionException

Specified by:

toMessage in interface StreamMessageConverter

Throws:

MessageConversionException

fromMessage

public com.rabbitmq.stream.Message fromMessage(Message message)
                                        throws MessageConversionException

Description copied from interface: MessageConverter

Convert from a Message to a Java object.

Specified by:

fromMessage in interface MessageConverter

Specified by:

fromMessage in interface StreamMessageConverter

Parameters:

message - the message to convert

Returns:

the converted Java object

Throws:

MessageConversionException - in case of conversion failure