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 | a65aac4bb26169b1277ef29f147f4435fb105c52 (patch) | |
| tree | c14b22a6d3c25c2e02497d457a0b17b9374fef4a /src | |
| parent | 5ed1782eda1ef139a807cbce2a99af44eefe3835 (diff) | |
| download | rabbitmq-server-git-a65aac4bb26169b1277ef29f147f4435fb105c52.tar.gz | |
include channel# in unknown_frame error
Diffstat (limited to 'src')
| -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 690e6f0e38..761794f15b 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 -> |