В данном разделе представлены команды управления кластерами с ролью BUS.
<CLUSTER> - имя кластера с ролью BUS.
delete
Команда удаления AMQP-объекта с брокера.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/delete
Синтаксис:
delete <OBJECT> where <WHERE_CONDITION>
Параметры:
<OBJECT> - AMQP-объект;
<WHERE_CONDITION> - условие отбора удаляемой записи.
Пример:
ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/delete queue where name = cowboy_client2.10.0.ecss-10-system.rps.c [delete] You are going to delete 13 object(s) forever. You can corrupt broker data and interrupt active calls. THINK TWICE Selected objects: cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.ds1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.tts1.tts1@leonid1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.ds1.ds1@leonid1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.md1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.core1.core1@leonid1 .q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.pa_sip1.pa_sip1@leo nid1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.tts1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.mycelium-mycelium1. q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.pa_sip1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.md1.md1@leonid1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.core1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.mycelium-mycelium1. mycelium1@leonid1.q cowboy_client2.10.0.ecss-10-system.rps.clusters.monitoring.q Are you sure?: [n]/y ?> y
list
Команда просмотра списка AMQP-объектов на брокере.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/list
Синтаксис:
list [<OBJECT>]
Параметры:
<OBJECT> - AMQP-объект.
Пример:
ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/list ----------------------- |#| Object |Number| |-+------------+------| |1|Session |111 | |2|Queue |120 | |3|Subscription|174 | |4|Exchange |16 | |5|Binding |313 | |6|Connections |30 | |7|Nodes |1 | -----------------------
ping
Команда измерения латентности взаимодействия с AMQP-брокером.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/ping
Синтаксис:
ping [<TestNum> [<Timeout>]]
Параметры:
<TestNum> - количество ping-запросов;
<Timeout> - время между отправкой повторных ping-запросов.
Пример:
ecss-root@[mycelium1@leonid1]:/# cluster/bus/mycelium1/ping total=1112 net=921 route=8 qu=46 session=137 total=893 net=714 route=7 qu=31 session=141 total=1111 net=910 route=8 qu=26 session=167 total=1141 net=958 route=58 qu=27 session=98 total=973 net=774 route=8 qu=54 session=137 --- ping statistics --- 5 messages transmitted, 5 messages received, 0 messages loss avarage: total=1046 net=855 route=17 qu=36 session=136
reset_stat
Команда для сброса статистики AMQP-объекта на брокере.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/reset_stat
Синтаксис:
reset_stat <QUEUE> where <WHERE_CONDITION>
Параметры:
<QUEUE> - имя очереди;
<WHERE_CONDITION> - условия отбора записи.
Пример:
support@[mycelium1@biysk1]:/$ cluster/bus/mycelium1@biysk1/reset_stat queue where depth > 3
show
Команда просмотра параметров AMQP-объекта на брокере.
Путь команды:
/cluster/bus/<NODE@CLUSTER>/show
Синтаксис:
show message <Qu> <MsgId> - просмотр информации об определенном сообщении в очереди
show rejected <Node>/<MsgId> - просмотр информации об определенном сообщении, которое было отклонено
show queue <Qu> - просмотр информации об определенной очереди
Параметры:
<Qu> - очередь AMQP;
<MsgId> - идентификатор сообщения;
<Node> - имя ноды.
Пример:
Информация об очереди:
/cluster/bus/ecss_mycelium@ubs64/show queue ecss.rps.apf.q Name ecss.rps.apf.q Alternate exchange - Durable yes Exclusive no Auto delete no Pid <0.305.0> Uptime 4d 03:11:18 Subscription number 0 Depth 480 Messages in/out 31099/30619 Max depth 1001 drop_num 12307 Lifetime interval (ms) GC period (ms) never Maximum possible depth undefined drop_type drop arrived message Warning on overlow yes shuffle_subs no