From 81bba753aa2aa2226f08b5ef5b19de09f774ed59 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?=
 <514737+acogoluegnes@users.noreply.github.com>
Date: Wed, 10 Sep 2025 16:59:16 +0200
Subject: [PATCH] Null-proof reply post processor in request/response classes

---
 .../java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java b/src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java
index 5e3822840f..d29ec9dfb0 100644
--- a/src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java
+++ b/src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java
@@ -85,7 +85,13 @@ public Message message(byte[] body) {
       this.correlationIdExtractor = builder.correlationIdExtractor();
     }
     if (builder.replyPostProcessor() == null) {
-      this.replyPostProcessor = Message::correlationId;
+      this.replyPostProcessor =
+          (msg, corrId) -> {
+            if (msg != null) {
+              msg.correlationId(corrId);
+            }
+            return msg;
+          };
     } else {
       this.replyPostProcessor = builder.replyPostProcessor();
     }