96
96
members ,
97
97
open_files ,
98
98
single_active_consumer_pid ,
99
- single_active_consumer_ctag ,
99
+ single_active_consumer_tag ,
100
100
messages_ram ,
101
101
message_bytes_ram ,
102
102
messages_dlx ,
@@ -456,7 +456,7 @@ handle_tick(QName,
456
456
messages_dlx ,
457
457
message_bytes_dlx ,
458
458
single_active_consumer_pid ,
459
- single_active_consumer_ctag
459
+ single_active_consumer_tag
460
460
],
461
461
{SacTag , SacPid } = maps :get (single_active_consumer_id ,
462
462
Overview , {'' , '' }),
@@ -472,7 +472,7 @@ handle_tick(QName,
472
472
{messages_persistent , NumMessages },
473
473
{messages_dlx , NumDiscarded + NumDiscardedCheckedOut },
474
474
{message_bytes_dlx , MsgBytesDiscarded },
475
- {single_active_consumer_ctag , SacTag },
475
+ {single_active_consumer_tag , SacTag },
476
476
{single_active_consumer_pid , SacPid }
477
477
| infos (QName , Keys )],
478
478
rabbit_core_metrics :queue_stats (QName , Infos ),
@@ -1461,7 +1461,7 @@ i(single_active_consumer_pid, Q) when ?is_amqqueue(Q) ->
1461
1461
{timeout , _ } ->
1462
1462
''
1463
1463
end ;
1464
- i (single_active_consumer_ctag , Q ) when ? is_amqqueue (Q ) ->
1464
+ i (single_active_consumer_tag , Q ) when ? is_amqqueue (Q ) ->
1465
1465
QPid = amqqueue :get_pid (Q ),
1466
1466
case ra :local_query (QPid ,
1467
1467
fun rabbit_fifo :query_single_active_consumer /1 ) of
0 commit comments