More logs

Author: dcorbacho

deps/rabbit/src/rabbit_amqqueue_process.erl

@@ -1293,8 +1293,10 @@ handle_call({basic_get, ChPid, NoAck, LimiterPid}, _From,
 handle_call({basic_consume, NoAck, ChPid, LimiterPid, LimiterActive,
              ModeOrPrefetch, ConsumerTag, ExclusiveConsume, Args, OkMsg, ActingUser},
             _From, State = #q{consumers = Consumers,
+                              q = Q,
                               active_consumer = Holder,
                               single_active_consumer_on = SingleActiveConsumerOn}) ->
+    rabbit_log:debug("TRACE basic_consume ~p", [amqqueue:get_name(Q)]),
     ConsumerRegistration = case SingleActiveConsumerOn of
         true ->
             case ExclusiveConsume of

deps/rabbit/src/rabbit_channel.erl

@@ -1697,6 +1697,7 @@ basic_consume(QueueName, NoAck, ConsumerPrefetch, ActualConsumerTag,
                           limiter = Limiter,
                           consumer_mapping  = ConsumerMapping,
                           queue_states = QueueStates0}) ->
+    rabbit_log:debug("TRACE basic_consume ~p", [QueueName]),
     case rabbit_amqqueue:with_exclusive_access_or_die(
            QueueName, ConnPid,
            fun (Q) ->

deps/rabbitmq_federation/test/queue_SUITE.erl

@@ -364,7 +364,7 @@ publish_expect(Ch, X, Key, Q, Payload) ->
 
 publish_expect(Config, Ch, X, Key, Q, Payload, Timeout) ->
     publish(Ch, X, Key, Payload),
-    ct:pal("Messages in broker ~p ", [rabbit_ct_broker_helpers:rabbitmqctl_list(Config, 0, ["list_queues", "name", "messages", "messages_ready"])]),
+    ct:pal("Messages in broker ~p ", [rabbit_ct_broker_helpers:rabbitmqctl_list(Config, 0, ["list_queues", "name", "messages", "messages_ready", "consumers"])]),
     Status = rabbit_ct_broker_helpers:rpc(Config, 0,
                                           rabbit_federation_status, status, []),
     ct:pal("Federation status ~p", [Status]),