如何通过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 (将#修改为@）

amqp spring