我有一個 Spring 應用程序，我們使用 spring-amqp 發布和監聽來自 Rabbitmq 的消息。如果我的監聽器拋出異常，我想修改我的 Rabbitmq 消息。當偵聽器拋出異常時，將使用恢復器和重試處理程序將其重新捕獲。我正在修改偵聽器類中存在的 catch 塊中的消息。一旦消息被修改，我就會拋出異常，以便在一段固定的時間后再次重試該消息。這是我用來修改消息的代碼。public void onMessage(Message message, Channel channel) throws Exception{        try        {            if(message.getMessageProperties().getHeaders().get("x-retried-header") != null)//self defined header            {                throw new MyException();            }            else            {                //some logic            }        }        catch(MyException e)        {            MyClass myObject = new MyClass();            myObject.setMessage("Hello Message Is Being Retried");            MessageProperties properties = message.getMessageProperties();            properties.setHeader("x-retried-header", 1);            message = MessageBuilder.withBody(myObject.toByteArray()).andProperties(properties).build();            throw new Exception();        }    }當我的恢復程序收到 RabbitMq 消息時，消息正文沒有更改，而我添加到修改后的消息中的標頭正在正確反映。我還可以在兔子處理程序中處理或修改我的消息，但我不想更改恢復程序和重試處理程序中的任何內容，因為其他偵聽器也使用了這些處理程序。有人可以幫我解決這個問題嗎？為什么我收到的是原始消息正文而不是修改后的消息正文？Spring-amqp 在這里使用任何克隆對象嗎？當偵聽器拋出異常時，是否有其他方法可以使用 spring-amqp 修改我的 RabbitMq 消息正文？