diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-14 19:27:44 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-07-14 19:27:44 +0100 |
| commit | 66752225e4c7417449a32a4e94e658dc8b6b79b5 (patch) | |
| tree | 94e62372153eb8caf5fe424051b15b2f96e5b367 /src/rabbit_reader.erl | |
| parent | e5b55dc25fe7bfbb923a163d1cbfbccb9870a9da (diff) | |
| download | rabbitmq-server-66752225e4c7417449a32a4e94e658dc8b6b79b5.tar.gz | |
cosmetic
Diffstat (limited to 'src/rabbit_reader.erl')
| -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 7972141c..86255790 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -541,8 +541,8 @@ handle_input(frame_header, <<Type:8,Channel:16,PayloadSize:32>>, State) -> switch_callback(State, {frame_payload, Type, Channel, PayloadSize}, PayloadSize + 1)); -handle_input({frame_payload, Type, Channel, PayloadSize}, - PayloadAndMarker, State) -> +handle_input({frame_payload, Type, Channel, PayloadSize}, PayloadAndMarker, + State) -> case PayloadAndMarker of <<Payload:PayloadSize/binary, ?FRAME_END>> -> switch_callback(handle_frame(Type, Channel, Payload, State), |