From 04f1801ae6eaac10af7bf802c8fb7065284624e6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?= Date: Thu, 15 Jun 2023 11:49:56 +0200 Subject: [PATCH] Tweak error message References #1062 (cherry picked from commit 5982cd1eb307004fe53353a01da03332aa342eb2) --- src/main/java/com/rabbitmq/client/impl/CommandAssembler.java | 4 +++- src/main/java/com/rabbitmq/client/impl/Frame.java | 4 +++- src/main/java/com/rabbitmq/client/impl/nio/FrameBuilder.java | 4 +++- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/rabbitmq/client/impl/CommandAssembler.java b/src/main/java/com/rabbitmq/client/impl/CommandAssembler.java index bc548efe7..2ff9f10e3 100644 --- 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 index 3608b37f2..d1332b79d 100644 --- 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 index a14bbaf17..3562e92a1 100644 --- 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 )); }