如何解决如何在自定义消息中使用RabbitTemplate sendAndReceive函数?
我是Spring AMQP的新手。我想通过自定义消息使用sendAndReceive()。
public void send (String exchange,String routingKey,MyCustomMessage message){
CorrelationData correlationData = new CorrelationData("correlation-data");
rabbitTemplate.sendAndReceive(exchange,routingKey,message,correlationData);
}
使'MyCustomMessage'扩展org.springframework.amqp.core.Message'
扩展消息是使用CustomMessage的唯一方法吗? 使用convertAndSend函数时,我没有扩展。
解决方法
否;只要它与模板中的MessageConverter
兼容(默认SimpleMessageConverter
可以处理Serializable
,或者您可以将Jackson2JsonMessageConverter
用于JSON友好类,或者您可以使用自定义消息转换器)。
然后,使用template.convertSendAndReceive(...)
代替sendAndReceive
。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。