public class DefaultStreamMessageConverter extends java.lang.Object implements StreamMessageConverter
StreamMessageConverter.| Constructor and Description |
|---|
DefaultStreamMessageConverter()
Construct an instance using a
WrapperMessageBuilder. |
DefaultStreamMessageConverter(com.rabbitmq.stream.Codec codec)
Construct an instance using the provided codec.
|
| Modifier and Type | Method and Description |
|---|---|
com.rabbitmq.stream.Message |
fromMessage(org.springframework.amqp.core.Message message) |
void |
setBuilderSupplier(java.util.function.Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)
Set a supplier for a message builder.
|
org.springframework.amqp.core.Message |
toMessage(java.lang.Object object,
StreamMessageProperties messageProperties) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waittoMessagepublic DefaultStreamMessageConverter()
WrapperMessageBuilder.public DefaultStreamMessageConverter(@Nullable
com.rabbitmq.stream.Codec codec)
codec - the codec.public void setBuilderSupplier(java.util.function.Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)
builderSupplier - the supplier.public org.springframework.amqp.core.Message toMessage(java.lang.Object object,
StreamMessageProperties messageProperties)
throws org.springframework.amqp.support.converter.MessageConversionException
toMessage in interface StreamMessageConverterorg.springframework.amqp.support.converter.MessageConversionExceptionpublic com.rabbitmq.stream.Message fromMessage(org.springframework.amqp.core.Message message)
throws org.springframework.amqp.support.converter.MessageConversionException
fromMessage in interface org.springframework.amqp.support.converter.MessageConverterfromMessage in interface StreamMessageConverterorg.springframework.amqp.support.converter.MessageConversionException