diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-12 11:02:54 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-12 11:02:54 +0100 |
| commit | 5e9788c190df6c8bd528752748a67448d5efc422 (patch) | |
| tree | 8067fdac59f6dd12f23eb8a77680b8b7a4b25402 | |
| parent | 02a6486e64dd8828acaea1a06a2e6b7e05c94cf8 (diff) | |
| download | rabbitmq-server-git-5e9788c190df6c8bd528752748a67448d5efc422.tar.gz | |
Catch enotconn here.
| -rw-r--r-- | src/rabbit_reader.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 68cef56aff..4d4ce4a2b1 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -858,7 +858,7 @@ handle_method0(MethodName, FieldsBin, try handle_method0(Protocol:decode_method_fields(MethodName, FieldsBin), State) - catch throw:{inet_error, closed} -> + catch throw:{inet_error, E} when E =:= closed; E =:= enotconn -> maybe_emit_stats(State), throw(connection_closed_abruptly); exit:#amqp_error{method = none} = Reason -> |