如何将RabbitTemplate sendAndReceive函数与自定义消息一起使用

Question

我是Spring AMQP的新手。我想使用sendAndReceive((来使用自定义消息。

public void send (String exchange, String routingKey, MyCustomMessage message){
CorrelationData correlationData = new CorrelationData("correlation-data");
rabbitTemplate.sendAndReceive(exchange, routingKey, message, correlationData);
}

但此代码出现错误消息

Make'MyCustomMessage'extennds org.springframework.amqp.core.Message'

扩展消息是使用CustomMessage的唯一方法吗？当我使用convertAndSend函数时，我没有进行扩展。

Answer 1

否；只要它与模板中的MessageConverter兼容(默认的SimpleMessageConverter可以处理Serializable，也可以将Jackson2JsonMessageConverter用于JSON友好类，或者可以使用自定义消息转换器(。

然后，使用template.convertSendAndReceive(...)而不是sendAndReceive。