From e072dd55d9b99f2a5f11621eb1dadc3014f18437 Mon Sep 17 00:00:00 2001 From: Simon MacMullen Date: Wed, 13 Aug 2014 15:45:15 +0100 Subject: [PATCH] cosmetic --- src/amqp_channel.erl | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/src/amqp_channel.erl b/src/amqp_channel.erl index 67406d21..b7f83535 100644 --- a/src/amqp_channel.erl +++ b/src/amqp_channel.erl @@ -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 @@ -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;