summaryrefslogtreecommitdiff
path: root/src/rabbit_reader.erl
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-01-06 08:42:56 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2011-01-06 08:42:56 +0000
commit5b673b52e76cc2880e78f0557e03dcb83c43c420 (patch)
tree6c04fea6c6c852669ac269d3c9cbb1cb8283c2e6 /src/rabbit_reader.erl
parent663ffcaaf9c0a96709f7c9790888a62b606020e7 (diff)
downloadrabbitmq-server-5b673b52e76cc2880e78f0557e03dcb83c43c420.tar.gz
cosmetic
Diffstat (limited to 'src/rabbit_reader.erl')
-rw-r--r--src/rabbit_reader.erl14
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.