Class DefaultStreamMessageConverter
- java.lang.Object
-
- org.springframework.rabbit.stream.support.converter.DefaultStreamMessageConverter
-
- All Implemented Interfaces:
org.springframework.amqp.support.converter.MessageConverter,StreamMessageConverter
public class DefaultStreamMessageConverter extends java.lang.Object implements StreamMessageConverter
DefaultStreamMessageConverter.- Since:
- 2.4
-
-
Constructor Summary
Constructors Constructor Description DefaultStreamMessageConverter()Construct an instance using aWrapperMessageBuilder.DefaultStreamMessageConverter(com.rabbitmq.stream.Codec codec)Construct an instance using the provided codec.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.rabbitmq.stream.MessagefromMessage(org.springframework.amqp.core.Message message)voidsetBuilderSupplier(java.util.function.Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)Set a supplier for a message builder.org.springframework.amqp.core.MessagetoMessage(java.lang.Object object, StreamMessageProperties messageProperties)-
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.support.converter.MessageConverter
toMessage
-
Methods inherited from interface org.springframework.rabbit.stream.support.converter.StreamMessageConverter
toMessage
-
-
-
-
Constructor Detail
-
DefaultStreamMessageConverter
public DefaultStreamMessageConverter()
Construct an instance using aWrapperMessageBuilder.
-
DefaultStreamMessageConverter
public DefaultStreamMessageConverter(@Nullable com.rabbitmq.stream.Codec codec)Construct an instance using the provided codec.- Parameters:
codec- the codec.
-
-
Method Detail
-
setBuilderSupplier
public void setBuilderSupplier(java.util.function.Supplier<com.rabbitmq.stream.MessageBuilder> builderSupplier)
Set a supplier for a message builder.- Parameters:
builderSupplier- the supplier.
-
toMessage
public org.springframework.amqp.core.Message toMessage(java.lang.Object object, StreamMessageProperties messageProperties) throws org.springframework.amqp.support.converter.MessageConversionException- Specified by:
toMessagein interfaceStreamMessageConverter- Throws:
org.springframework.amqp.support.converter.MessageConversionException
-
fromMessage
public com.rabbitmq.stream.Message fromMessage(org.springframework.amqp.core.Message message) throws org.springframework.amqp.support.converter.MessageConversionException- Specified by:
fromMessagein interfaceorg.springframework.amqp.support.converter.MessageConverter- Specified by:
fromMessagein interfaceStreamMessageConverter- Throws:
org.springframework.amqp.support.converter.MessageConversionException
-
-