diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-06 08:42:56 +0000 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-06 08:42:56 +0000 |
commit | 5b673b52e76cc2880e78f0557e03dcb83c43c420 (patch) | |
tree | 6c04fea6c6c852669ac269d3c9cbb1cb8283c2e6 | |
parent | 663ffcaaf9c0a96709f7c9790888a62b606020e7 (diff) | |
download | rabbitmq-server-5b673b52e76cc2880e78f0557e03dcb83c43c420.tar.gz |
cosmetic
-rw-r--r-- | src/rabbit_reader.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 16faf586..48bc6be2 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -952,19 +952,19 @@ send_to_new_channel(Channel, AnalyzedFrame, State) -> process_channel_frame(AnalyzedFrame, Channel, ChPid, AState, State). process_channel_frame(Frame, Channel, ChPid, AState, State) -> - UpdateFramingState = fun (NewAState) -> - put({channel, Channel}, {ChPid, NewAState}), - State - end, + UpdateAState = fun (NewAState) -> + put({channel, Channel}, {ChPid, NewAState}), + State + end, case rabbit_command_assembler:process(Frame, AState) of {ok, NewAState} -> - UpdateFramingState(NewAState); + UpdateAState(NewAState); {ok, Method, NewAState} -> rabbit_channel:do(ChPid, Method), - UpdateFramingState(NewAState); + UpdateAState(NewAState); {ok, Method, Content, NewAState} -> rabbit_channel:do(ChPid, Method, Content), - UpdateFramingState(NewAState); + UpdateAState(NewAState); {error, Reason} -> handle_exception(State, Channel, Reason) end. |