Apply PR formatting feedback

#13625 (comment)
#13625 (comment)
(cherry picked from commit c151806)

Author: ansd

deps/rabbit/src/rabbit_channel.erl

@@ -1354,10 +1354,9 @@ handle_method(#'basic.consume'{queue        = QueueNameBin,
     CurrentConsumers = maps:size(ConsumerMapping),
     case maps:find(ConsumerTag, ConsumerMapping) of
         error when CurrentConsumers >= MaxConsumers ->  % false when MaxConsumers is 'infinity'
-            rabbit_misc:protocol_error(
-              not_allowed,
-              "reached maximum (~B) of consumers per channel",
-              [MaxConsumers]);
+            rabbit_misc:protocol_error(not_allowed,
+                                       "reached maximum (~B) of consumers per channel",
+                                       [MaxConsumers]);
         error ->
             QueueName = qbin_to_resource(QueueNameBin, VHostPath),
             check_read_permitted(QueueName, User, AuthzContext),
@@ -1368,13 +1367,13 @@ handle_method(#'basic.consume'{queue        = QueueNameBin,
                             _ ->
                                 ConsumerTag
                         end,
-            basic_consume(
-              QueueName, NoAck, ConsumerPrefetch, ActualTag,
-              ExclusiveConsume, Args, NoWait, State);
+            basic_consume(QueueName, NoAck, ConsumerPrefetch, ActualTag,
+                          ExclusiveConsume, Args, NoWait, State);
         {ok, _} ->
             %% Attempted reuse of consumer tag.
-            rabbit_misc:protocol_error(
-              not_allowed, "attempt to reuse consumer tag '~ts'", [ConsumerTag])
+            rabbit_misc:protocol_error(not_allowed,
+                                       "attempt to reuse consumer tag '~ts'",
+                                       [ConsumerTag])
     end;
 
 handle_method(#'basic.cancel'{consumer_tag = ConsumerTag, nowait = NoWait},

deps/rabbit/src/rabbit_queue_type.erl

@@ -522,7 +522,7 @@ consume(Q, Spec, State) ->
     case Mod:consume(Q, Spec, CtxState0) of
         {ok, CtxState} ->
             {ok, set_ctx(Q, Ctx#ctx{state = CtxState}, State)};
-        Err = {error, _Type, _Fmt, _FmtArgs} ->
+        {error, _Type, _Fmt, _FmtArgs} = Err->
             Err
     end.
 

deps/rabbit/src/rabbit_quorum_queue.erl

@@ -1010,8 +1010,7 @@ consume(Q, Spec, QState0) when ?amqqueue_is_quorum(Q) ->
                      args => Args,
                      username => ActingUser,
                      priority => Priority},
-    case rabbit_fifo_client:checkout(
-           ConsumerTag, Mode, ConsumerMeta, QState0) of
+    case rabbit_fifo_client:checkout(ConsumerTag, Mode, ConsumerMeta, QState0) of
         {ok, _Infos, QState} ->
             case single_active_consumer_on(Q) of
                 true ->
@@ -1024,29 +1023,30 @@ consume(Q, Spec, QState0) when ?amqqueue_is_quorum(Q) ->
                                                  _ ->
                                                      waiting
                                              end,
-                            rabbit_core_metrics:consumer_created(
-                              ChPid, ConsumerTag, ExclusiveConsume,
-                              AckRequired, QName,
-                              Prefetch, ActivityStatus == single_active, %% Active
-                              ActivityStatus, Args),
-                            emit_consumer_created(
-                              ChPid, ConsumerTag, ExclusiveConsume,
-                              AckRequired, QName, Prefetch,
-                              Args, none, ActingUser),
+                            rabbit_core_metrics:consumer_created(ChPid, ConsumerTag,
+                                                                 ExclusiveConsume,
+                                                                 AckRequired, QName,
+                                                                 Prefetch,
+                                                                 ActivityStatus == single_active,
+                                                                 ActivityStatus, Args),
+                            emit_consumer_created(ChPid, ConsumerTag,
+                                                  ExclusiveConsume,
+                                                  AckRequired, QName,
+                                                  Prefetch, Args, none,
+                                                  ActingUser),
                             {ok, QState};
                         Err ->
                             consume_error(Err, QName)
                     end;
                 false ->
-                    rabbit_core_metrics:consumer_created(
-                      ChPid, ConsumerTag, ExclusiveConsume,
-                      AckRequired, QName,
-                      Prefetch, true, %% Active
-                      up, Args),
-                    emit_consumer_created(
-                      ChPid, ConsumerTag, ExclusiveConsume,
-                      AckRequired, QName, Prefetch,
-                      Args, none, ActingUser),
+                    rabbit_core_metrics:consumer_created(ChPid, ConsumerTag,
+                                                         ExclusiveConsume,
+                                                         AckRequired, QName,
+                                                         Prefetch, true,
+                                                         up, Args),
+                    emit_consumer_created(ChPid, ConsumerTag, ExclusiveConsume,
+                                          AckRequired, QName, Prefetch,
+                                          Args, none, ActingUser),
                     {ok, QState}
             end;
         Err ->