如何解决如何通过Spring接收JSON编码的AMQP RabbitMQ消息的大小/长度?
我正在使用Spring 2.2.2.RELEASE通过Spring的AmqpTemplate
来发送和接收消息。 RabbitTemplate
。
我的@RabbitListener
收到@Payload
作为输入,加上一些专用的@Header
字段,例如相关ID。有效载荷以POJO的形式接收,依靠Spring的标准映射器进行JSON到对象的转换。
@Transactional(propagation = Propagation.REQUIRED)
@RabbitListener(queues = CloudRabbitConfig.MY_QUEUE_NAME)
public void receiveWatchlistData(
@Payload InboundMessageMessage message,@Header(value = AmqpHeaders.CORRELATION_ID,required = false) String correlationId)
throws IOException{
我想记录JSON字符串编码的消息的大小或长度,例如“收到大小为{}个字节/字符的消息”。
是否有一种方法可以使侦听器也接收消息的属性,例如作为另一个@Header
?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。