diff options
| author | Tim Watson <tim@rabbitmq.com> | 2012-07-16 10:38:31 +0100 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2012-07-16 10:38:31 +0100 |
| commit | 067776e41e6442f6ab5ef82653f53ce113003b1b (patch) | |
| tree | 304cb2a8a38b6be9b1088a0dce4d3dde3580cdcc | |
| parent | f56bcf6afbb8363e5b3f8709e852c663804b77b0 (diff) | |
| download | rabbitmq-server-git-067776e41e6442f6ab5ef82653f53ce113003b1b.tar.gz | |
oops - handle heartbeat timeouts properly in closed state
| -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 bd5cf58845..518021a49f 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -311,7 +311,7 @@ handle_other(handshake_timeout, Deb, State) mainloop(Deb, State); handle_other(handshake_timeout, _Deb, State) -> throw({handshake_timeout, State#v1.callback}); -handle_other(timeout, Deb, State = #v1{connection_state = closed}) -> +handle_other(heartbeat_timeout, Deb, State = #v1{connection_state = closed}) -> mainloop(Deb, State); handle_other(heartbeat_timeout, _Deb, #v1{connection_state = S}) -> throw({heartbeat_timeout, S}); |