root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #6502 from rabbitmq/lh-fix-sac-crash 

CQ: Remove an assert causing issues on SAC switch
This commit is contained in:
Michael Klishin 2022-11-29 00:37:44 +04:00 committed by GitHub
parent a52481dd98 59e3c704fa
commit 2767feb031
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbit/src/rabbit_amqqueue_process.erl vendored
View File

@ -686,8 +686,7 @@ attempt_delivery(Delivery = #delivery{sender = SenderPid,
backing_queue_state = BQS,
msg_id_to_channel = MTC}) ->
case rabbit_queue_consumers:deliver(
fun (true) -> true = BQ:is_empty(BQS),
{AckTag, BQS1} =
fun (true) -> {AckTag, BQS1} =
BQ:publish_delivered(
Message, Props, SenderPid, Flow, BQS),
{{Message, Delivered, AckTag}, {BQS1, MTC}};