diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-09-21 08:22:59 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-09-21 08:22:59 +0100 |
| commit | 10fb1ebf5b464101b11989a333cee73f3d02c2c8 (patch) | |
| tree | c14b22a6d3c25c2e02497d457a0b17b9374fef4a | |
| parent | eed4bb4ed5256e300c8f25ea93fd1ad30a0f8fd4 (diff) | |
| download | rabbitmq-server-10fb1ebf5b464101b11989a333cee73f3d02c2c8.tar.gz | |
include channel# in unknown_frame error
| -rw-r--r-- | src/rabbit_reader.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 690e6f0e..761794f1 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -451,7 +451,7 @@ handle_frame(_Type, _Channel, _Payload, State = #v1{connection_state = CS}) State; handle_frame(Type, 0, Payload, State) -> case analyze_frame(Type, Payload) of - error -> throw({unknown_frame, Type, Payload}); + error -> throw({unknown_frame, 0, Type, Payload}); heartbeat -> State; trace -> State; {method, MethodName, FieldsBin} -> @@ -460,7 +460,7 @@ handle_frame(Type, 0, Payload, State) -> end; handle_frame(Type, Channel, Payload, State) -> case analyze_frame(Type, Payload) of - error -> throw({unknown_frame, Type, Payload}); + error -> throw({unknown_frame, Channel, Type, Payload}); heartbeat -> throw({unexpected_heartbeat_frame, Channel}); trace -> throw({unexpected_trace_frame, Channel}); AnalyzedFrame -> |