Skip to content

Commit ce3726c

Browse files
committed
Fix splitting large messages in server
This commit fixes the following test case: ``` make -C deps/rabbit ct-amqp_dotnet t=cluster_size_1:fragmentation ``` Previously, the server sent a frame that was 1 byte too large.
1 parent 64fdb25 commit ce3726c

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

deps/rabbit/src/rabbit_amqp_session.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2182,7 +2182,8 @@ handle_deliver(ConsumerTag, AckRequired,
21822182
delivery_id = ?UINT(DeliveryId),
21832183
delivery_tag = {binary, Dtag},
21842184
message_format = ?UINT(?MESSAGE_FORMAT),
2185-
settled = SendSettled},
2185+
settled = SendSettled,
2186+
more = false},
21862187
Mc1 = rabbit_msg_interceptor:intercept_outgoing(Mc0, MsgIcptCtx),
21872188
Mc2 = mc:convert(mc_amqp, Mc1),
21882189
Mc = mc:set_annotation(redelivered, Redelivered, Mc2),
@@ -2332,7 +2333,8 @@ incoming_mgmt_link_transfer(
23322333
delivery_id = ?UINT(OutgoingDeliveryId),
23332334
delivery_tag = {binary, <<>>},
23342335
message_format = ?UINT(?MESSAGE_FORMAT),
2335-
settled = true},
2336+
settled = true,
2337+
more = false},
23362338
validate_message_size(Response, OutgoingMaxMessageSize),
23372339
Frames = transfer_frames(Transfer, Response, MaxFrameSize),
23382340
PendingDelivery = #pending_management_delivery{frames = Frames},

0 commit comments

Comments
 (0)