Skip to content

Commit 8a7e296

Browse files
committed
Fix type issues with send_drained message
For quorum queues. [#165796741]
1 parent a4033d8 commit 8a7e296

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/rabbit_fifo.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ apply(Meta, #credit{credit = NewCredit, delivery_count = RemoteDelCnt,
236236
{State1#?MODULE{consumers = Consumers},
237237
%% returning a multi response with two client actions
238238
%% for the channel to execute
239-
{multi, [Response, {send_drained, [{CTag, Drained}]}]},
239+
{multi, [Response, {send_drained, {CTag, Drained}}]},
240240
Effects}
241241
end;
242242
_ when Waiting0 /= [] ->

test/rabbit_fifo_SUITE.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ credit_with_drained_test(_) ->
138138
delivery_count = 5}}},
139139
State),
140140
?assertEqual({multi, [{send_credit_reply, 0},
141-
{send_drained, [{?FUNCTION_NAME, 5}]}]},
141+
{send_drained, {?FUNCTION_NAME, 5}}]},
142142
Result),
143143
ok.
144144

@@ -153,7 +153,7 @@ credit_and_drain_test(_) ->
153153

154154
?ASSERT_NO_EFF({send_msg, _, {delivery, _, _}}, CheckEffs),
155155
{State4, {multi, [{send_credit_reply, 0},
156-
{send_drained, [{?FUNCTION_NAME, 2}]}]},
156+
{send_drained, {?FUNCTION_NAME, 2}}]},
157157
Effects} = apply(meta(4), rabbit_fifo:make_credit(Cid, 4, 0, true), State3),
158158
?assertMatch(#rabbit_fifo{consumers = #{Cid := #consumer{credit = 0,
159159
delivery_count = 4}}},

0 commit comments

Comments
 (0)