diff options
| -rw-r--r-- | src/rabbit_msg_store.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 2322f0f9..1562050c 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -887,7 +887,7 @@ handle_info(sync, State) -> handle_info(timeout, State) -> noreply(internal_sync(State)); -handle_info({'DOWN', _MRef, Pid, _Reason}, State) -> +handle_info({'DOWN', _MRef, process, Pid, _Reason}, State) -> credit_flow:peer_down(Pid), noreply(State); |