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 Object implements StreamMessageConverter
Since:
2.4
  • Constructor Details

    • DefaultStreamMessageConverter

      public DefaultStreamMessageConverter()
      Construct an instance using a WrapperMessageBuilder.
    • DefaultStreamMessageConverter

      public DefaultStreamMessageConverter(@Nullable 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 org.springframework.amqp.core.Message toMessage(Object object, StreamMessageProperties messageProperties) throws org.springframework.amqp.support.converter.MessageConversionException
      Specified by:
      toMessage in interface StreamMessageConverter
      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:
      fromMessage in interface org.springframework.amqp.support.converter.MessageConverter
      Specified by:
      fromMessage in interface StreamMessageConverter
      Throws:
      org.springframework.amqp.support.converter.MessageConversionException