Skip to content

Instantly share code, notes, and snippets.

@hughsaunders

hughsaunders/So all the messages are in the scheduler_fanout queue, how did I miss that via rabbitmqctl? Oh because it isn't listed:

Last active December 2, 2015 10:37
Show Gist options
  • Save hughsaunders/e59c1b935e45786b201c to your computer and use it in GitHub Desktop.
Save hughsaunders/e59c1b935e45786b201c to your computer and use it in GitHub Desktop.
Download ZIP
Where are all the messages if they aren't in a queue?
Raw
check message count via api
# curl http://user:pass@host:15672/api/overview 2>/dev/null |jq '.["queue_totals"]["messages"]'
359
Raw
check queue totals via api
# curl http://ser:pass@host:15672/api/queues 2>/dev/null |jq '.[]| select(.messages >0)|{name: .name, msgs:.messages}'
{
"msgs": 106,
"name": "q-metering-plugin"
}
{
"msgs": 286,
"name": "scheduler_fanout_4b4311e0afef48829136edb1f5156145"
}
Raw
check queue totals via rabbitmqctl
# rabbitmqctl list_queues |awk '{if($2>0)print $0}'
Listing queues ...
q-metering-plugin 81
Raw
So all the messages are in the scheduler_fanout queue, how did I miss that via rabbitmqctl? Oh because it isn't listed:
# ansible rabbitmq_all -m shell -a 'rabbitmqctl list_queues |grep scheduler_fanout'
rpc-partition_rabbit_mq_container-58d015b1 | success | rc=0 >>
cinder-scheduler_fanout_61abd8c59f67445fbf02e2c96151eef2 0
rpc-partition_rabbit_mq_container-5079f706 | success | rc=0 >>
cinder-scheduler_fanout_61abd8c59f67445fbf02e2c96151eef2 0
rpc-partition_rabbit_mq_container-56acfe95 | success | rc=0 >>
cinder-scheduler_fanout_61abd8c59f67445fbf02e2c96151eef2 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment