Skip to content
This repository has been archived by the owner on Nov 18, 2020. It is now read-only.

Commit

Permalink
cosmetic
Browse files Browse the repository at this point in the history
  • Loading branch information
Simon MacMullen committed Aug 13, 2014
1 parent beff3ac commit e072dd5
Showing 1 changed file with 5 additions and 8 deletions.
13 changes: 5 additions & 8 deletions src/amqp_channel.erl
Original file line number Diff line number Diff line change
Expand Up @@ -485,12 +485,10 @@ handle_info({send_command_and_notify, QPid, ChPid,
Method = #'basic.deliver'{}, Content},
State = #state{delivery_flow_control = MFC}) ->
case MFC of
false ->
handle_method_from_server(Method, Content, State),
rabbit_amqqueue:notify_sent(QPid, ChPid);
true ->
handle_method_from_server(Method, Content,
{self(), QPid, ChPid}, State)
false -> handle_method_from_server(Method, Content, State),
rabbit_amqqueue:notify_sent(QPid, ChPid);
true -> handle_method_from_server(Method, Content,
{self(), QPid, ChPid}, State)
end,
{noreply, State};
%% This comes from the writer or rabbit_channel
Expand Down Expand Up @@ -976,8 +974,7 @@ handle_wait_for_confirms(From, Timeout,
call_to_consumer(Method, Args, #state{consumer = Consumer}) ->
amqp_gen_consumer:call_consumer(Consumer, Method, Args).

call_to_consumer(Method, Args, DeliveryCtx,
#state{consumer = Consumer}) ->
call_to_consumer(Method, Args, DeliveryCtx, #state{consumer = Consumer}) ->
amqp_gen_consumer:call_consumer(Consumer, Method, Args, DeliveryCtx).

safe_cancel_timer(undefined) -> ok;
Expand Down

0 comments on commit e072dd5

Please sign in to comment.