目的：消息重试3次后将此消息入库并告警 
目前的做法：我在发送者端添加了请求头retryCount表示重试次数，初始化为0。在消费者端接收该消息，如果发生异常则重试次数+1，如果重试次数大于3则入库告警。 
问题：当发生异常后，重试次数重新接收后仍然为0，并非+1后的数据。 
麻烦各位老哥帮忙看看，谢谢啦。 

发送者代码：

    public String sendEmail(MessageEntity msg) {

        // 创建消息处理器，用于设置消息属性
        MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message ...