bugfix

Author: davidda

projects/RabbitMQ.Client/AmqpTcpEndpoint.cs

@@ -78,7 +78,7 @@ public AmqpTcpEndpoint(string hostName, int portOrMinusOne, SslOption ssl,
             _port = portOrMinusOne;
             Ssl = ssl;
             _maxInboundMessageBodySize = Math.Min(maxInboundMessageBodySize,
-                InternalConstants.DefaultRabbitMqMaxInboundMessageBodySize);
+                InternalConstants.MaximumRabbitMqMaxInboundMessageBodySize);
         }
 
         /// <summary>

projects/RabbitMQ.Client/InternalConstants.cs

@@ -41,9 +41,9 @@ internal static class InternalConstants
         /// <summary>
         /// Largest message size, in bytes, allowed in RabbitMQ.        
         /// Note: <code>rabbit.max_message_size</code> setting (https://www.rabbitmq.com/configure.html)
-        /// configures the largest message size which should be lower than this maximum of 128MiB.
+        /// configures the largest message size which should not be higher than this maximum of 512MiB.
         /// </summary>
-        internal const uint DefaultRabbitMqMaxInboundMessageBodySize = 1_048_576 * 128;
+        internal const uint MaximumRabbitMqMaxInboundMessageBodySize = 1_048_576 * 512;
 
         /// <summary>
         /// Largest client provide name, in characters, allowed in RabbitMQ.

projects/Test/Integration/TestConnectionFactory.cs

@@ -320,8 +320,8 @@ public async Task TestCreateConnectionUsesValidEndpointWhenMultipleSupplied()
         public void TestCreateAmqpTCPEndPointOverridesMaxMessageSizeWhenGreaterThanMaximumAllowed()
         {
             var ep = new AmqpTcpEndpoint("localhost", -1, new SslOption(),
-                2 * InternalConstants.DefaultRabbitMqMaxInboundMessageBodySize);
-            Assert.Equal(InternalConstants.DefaultRabbitMqMaxInboundMessageBodySize, ep.MaxInboundMessageBodySize);
+                2 * InternalConstants.MaximumRabbitMqMaxInboundMessageBodySize);
+            Assert.Equal(InternalConstants.MaximumRabbitMqMaxInboundMessageBodySize, ep.MaxInboundMessageBodySize);
         }
 
         [Fact]