More logs

rabbitmq · Oct 25, 2024 · 0506d14 · 0506d14
1 parent f7d93fb
commit 0506d14
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/deps/rabbit/src/rabbit_amqqueue_process.erl b/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

diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl
@@ -1690,6 +1690,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) ->

diff --git a/deps/rabbitmq_federation/test/queue_SUITE.erl b/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]),