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 | 5001bcd203519da606bc1b40a7e10062de11613b (patch) | |
| tree | 6c04fea6c6c852669ac269d3c9cbb1cb8283c2e6 | |
| parent | d0bc5d50c36ab7399a8249e2146664609c3abf70 (diff) | |
| download | rabbitmq-server-git-5001bcd203519da606bc1b40a7e10062de11613b.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 16faf58667..48bc6be264 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. |
