Introduce a configurable limit to message size.

Add `max_message_size` configuration to configure limit
in bytes.
If message is bigger - channel exception will be thrown.

Default limit is 128MB.
There is still a hard limit of 521MB.

[#161983593]

1 files changed, 9 insertions, 1 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index d1f3b06528..f626f059a0 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -990,7 +990,15 @@ check_msg_size(Content) ->
     case Size > ?MAX_MSG_SIZE of
         true  -> precondition_failed("message size ~B larger than max size ~B",
                                      [Size, ?MAX_MSG_SIZE]);
-        false -> ok
+        false ->
+            case application:get_env(rabbit, max_message_size) of
+                {ok, MaxSize} when is_integer(MaxSize) andalso Size > MaxSize ->
+                    precondition_failed("message size ~B larger than"
+                                            " configured max size ~B",
+                                        [Size, MaxSize]);
+
+                _ -> ok
+            end
     end.
 
 check_vhost_queue_limit(#resource{name = QueueName}, VHost) ->