Tweak error message

References #1062 (cherry picked from commit 5982cd1)
rabbitmq · Jun 15, 2023 · 04f1801 · 04f1801
1 parent 714aae6
commit 04f1801
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/src/main/java/com/rabbitmq/client/impl/CommandAssembler.java b/src/main/java/com/rabbitmq/client/impl/CommandAssembler.java
@@ -107,7 +107,9 @@ private void consumeHeaderFrame(Frame f) throws IOException {
             long bodySize = this.contentHeader.getBodySize();
             if (bodySize >= this.maxBodyLength) {
                 throw new IllegalStateException(format(
-                    "Message body is too large (%d), maximum size is %d",
+                    "Message body is too large (%d), maximum configured size is %d. " +
+                        "See ConnectionFactory#setMaxInboundMessageBodySize " +
+                        "if you need to increase the limit.",
                     bodySize, this.maxBodyLength
                 ));
             }

diff --git a/src/main/java/com/rabbitmq/client/impl/Frame.java b/src/main/java/com/rabbitmq/client/impl/Frame.java
@@ -111,7 +111,9 @@ public static Frame readFrom(DataInputStream is, int maxPayloadSize) throws IOEx
         int payloadSize = is.readInt();
         if (payloadSize >= maxPayloadSize) {
             throw new IllegalStateException(format(
-                "Frame body is too large (%d), maximum size is %d",
+                "Frame body is too large (%d), maximum configured size is %d. " +
+                    "See ConnectionFactory#setMaxInboundMessageBodySize " +
+                    "if you need to increase the limit.",
                 payloadSize, maxPayloadSize
             ));
         }

diff --git a/src/main/java/com/rabbitmq/client/impl/nio/FrameBuilder.java b/src/main/java/com/rabbitmq/client/impl/nio/FrameBuilder.java
@@ -98,7 +98,9 @@ public Frame readFrame() throws IOException {
                 int framePayloadSize = (frameBuffer[0] << 24) + (frameBuffer[1] << 16) + (frameBuffer[2] << 8) + readFromBuffer();
                 if (framePayloadSize >= maxPayloadSize) {
                     throw new IllegalStateException(format(
-                        "Frame body is too large (%d), maximum size is %d",
+                        "Frame body is too large (%d), maximum configured size is %d. " +
+                            "See ConnectionFactory#setMaxInboundMessageBodySize " +
+                            "if you need to increase the limit.",
                         framePayloadSize, maxPayloadSize
                     ));
                 }