Interface StreamMessageConverter

All Superinterfaces:
org.springframework.amqp.support.converter.MessageConverter
All Known Implementing Classes:
DefaultStreamMessageConverter

public interface StreamMessageConverter extends org.springframework.amqp.support.converter.MessageConverter
Converts between Message and Message.
Since:
2.4
  • Method Summary

    Modifier and Type
    Method
    Description
    com.rabbitmq.stream.Message
    fromMessage(org.springframework.amqp.core.Message message)
     
    default org.springframework.amqp.core.Message
    toMessage(Object object, org.springframework.amqp.core.MessageProperties messageProperties)
     
    org.springframework.amqp.core.Message
    toMessage(Object object, StreamMessageProperties messageProperties)
     

    Methods inherited from interface org.springframework.amqp.support.converter.MessageConverter

    toMessage
  • Method Details

    • toMessage

      org.springframework.amqp.core.Message toMessage(Object object, StreamMessageProperties messageProperties) throws org.springframework.amqp.support.converter.MessageConversionException
      Throws:
      org.springframework.amqp.support.converter.MessageConversionException
    • toMessage

      default org.springframework.amqp.core.Message toMessage(Object object, org.springframework.amqp.core.MessageProperties messageProperties) throws org.springframework.amqp.support.converter.MessageConversionException
      Specified by:
      toMessage in interface org.springframework.amqp.support.converter.MessageConverter
      Throws:
      org.springframework.amqp.support.converter.MessageConversionException
    • fromMessage

      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
      Throws:
      org.springframework.amqp.support.converter.MessageConversionException