public interface StreamMessageConverter
extends org.springframework.amqp.support.converter.MessageConverter
Message and
Message.| Modifier and Type | Method and Description |
|---|---|
com.rabbitmq.stream.Message |
fromMessage(org.springframework.amqp.core.Message message) |
default org.springframework.amqp.core.Message |
toMessage(java.lang.Object object,
org.springframework.amqp.core.MessageProperties messageProperties) |
org.springframework.amqp.core.Message |
toMessage(java.lang.Object object,
StreamMessageProperties messageProperties) |
org.springframework.amqp.core.Message toMessage(java.lang.Object object,
StreamMessageProperties messageProperties)
throws org.springframework.amqp.support.converter.MessageConversionException
org.springframework.amqp.support.converter.MessageConversionExceptiondefault org.springframework.amqp.core.Message toMessage(java.lang.Object object,
org.springframework.amqp.core.MessageProperties messageProperties)
throws org.springframework.amqp.support.converter.MessageConversionException
toMessage in interface org.springframework.amqp.support.converter.MessageConverterorg.springframework.amqp.support.converter.MessageConversionExceptioncom.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.MessageConverterorg.springframework.amqp.support.converter.MessageConversionException