We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents d370b52 + b4a11e6 commit 7ec3703Copy full SHA for 7ec3703
deps/rabbit/src/rabbit_channel.erl
@@ -639,7 +639,12 @@ handle_cast(ready_for_close,
639
{stop, normal, State};
640
641
handle_cast(terminate, State = #ch{cfg = #conf{writer_pid = WriterPid}}) ->
642
- ok = rabbit_writer:flush(WriterPid),
+ try
643
+ ok = rabbit_writer:flush(WriterPid)
644
+ catch
645
+ _Class:Reason ->
646
+ rabbit_log:debug("Failed to flush pending writes on a terminating connection, reason: ~tp", [Reason])
647
+ end,
648
649
650
handle_cast({command, #'basic.consume_ok'{consumer_tag = CTag} = Msg},
0 commit comments