如何将 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'extends org.springframework.amqp.core.Message'

Extending Message 是使用CustomMessage 的唯一方法吗？我在使用 convertAndSend 函数时没有扩展。

Answer 1

否；只要它与模板中的 MessageConverter 兼容（默认 SimpleMessageConverter 可以处理 Serializable 或者您可以使用 Jackson2JsonMessageConverter 来处理 JSON-friendly 类，或者您可以使用自定义消息转换器）。

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

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

How to use RabbitTemplate sendAndReceive function with custom message?

spring

rabbitmq

spring-amqp