Class DefaultStreamMessageConverter

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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)  
      • 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
    • Constructor Detail

      • 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 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:
        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