parent
f3fa4cc6ab
commit
3d80af6a79
|
@ -640,7 +640,7 @@ handle_cast(terminate, State = #ch{cfg = #conf{writer_pid = WriterPid}}) ->
|
||||||
try
|
try
|
||||||
ok = rabbit_writer:flush(WriterPid)
|
ok = rabbit_writer:flush(WriterPid)
|
||||||
catch
|
catch
|
||||||
Class:Reason ->
|
_Class:Reason ->
|
||||||
rabbit_log:debug("Failed to flush pending writes on a terminating connection, reason: ~tp", [Reason])
|
rabbit_log:debug("Failed to flush pending writes on a terminating connection, reason: ~tp", [Reason])
|
||||||
end,
|
end,
|
||||||
{stop, normal, State};
|
{stop, normal, State};
|
||||||
|
|
Loading…
Reference in New Issue