max body size is frame_max - 8

cloudamqp · May 11, 2024 · 8562d0f · 8562d0f
1 parent 0a854c3
commit 8562d0f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/amqp-client/channel.cr b/src/amqp-client/channel.cr
@@ -278,9 +278,9 @@ class AMQP::Client
         c.unsafe_write Frame::Basic::Publish.new(@id, 0_u16, exchange, routing_key, mandatory, immediate)
         c.unsafe_write Frame::Header.new(@id, 60_u16, 0_u16, bytesize.to_u64, properties)
         pos = 0_u32
-        frame_max = @connection.frame_max
+        body_max = @connection.frame_max - 8
         until pos == bytesize
-          length = Math.min(frame_max, bytesize.to_u32 - pos)
+          length = Math.min(body_max, bytesize.to_u32 - pos)
           case body
           when Bytes
             c.unsafe_write Frame::BytesBody.new(@id, length, body[pos.to_i32, length.to_i32])