cosmetic

1 files changed, 9 insertions, 12 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 1bfda6d4b2..0535da7505 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -46,8 +46,7 @@
              transaction_id, tx_participants, next_tag,
              uncommitted_ack_q, unacked_message_q,
              username, virtual_host, most_recently_declared_queue,
-             consumer_mapping, blocking
-            }).
+             consumer_mapping, blocking}).
 
 -define(HIBERNATE_AFTER_MIN, 1000).
 -define(DESIRED_HIBERNATE, 10000).
@@ -349,13 +348,11 @@ queue_blocked(QPid, State = #ch{blocking = Blocking}) ->
         error      -> State;
         {ok, MRef} -> true = erlang:demonitor(MRef),
                       Blocking1 = dict:erase(QPid, Blocking),
-                      ok = case dict:size(Blocking1) =:= 0 of
-                               true ->
-                                   rabbit_writer:send_command(
-                                     State#ch.writer_pid,
-                                     #'channel.flow_ok'{active = false});
-                               false ->
-                                   ok
+                      ok = case dict:size(Blocking1) of
+                               0 -> rabbit_writer:send_command(
+                                      State#ch.writer_pid,
+                                      #'channel.flow_ok'{active = false});
+                               _ -> ok
                            end,
                       State#ch{blocking = Blocking1}
     end.
@@ -824,9 +821,9 @@ handle_method(#'channel.flow'{active = true}, _,
 handle_method(#'channel.flow'{active = false}, _,
               State = #ch{limiter_pid = LimiterPid,
                           consumer_mapping = Consumers}) ->
-    LimiterPid1 = case LimiterPid =:= undefined of
-                      true  -> start_limiter(State);
-                      false -> LimiterPid
+    LimiterPid1 = case LimiterPid of
+                      undefined -> start_limiter(State);
+                      Other     -> Other
                   end,
     ok = rabbit_limiter:block(LimiterPid1),
     QPids = consumer_queues(Consumers),