В данном разделе представлены команды управления кластерами с ролью BUS.

<NODE> - имя ноды.

<CLUSTER> - имя кластера с ролью BUS.

list

Команда просмотра списка AMQP-объектов на брокере.

Путь команды:

/cluster/bus/<CLUSTER>/list

Синтаксис:

list [<OBJECT>]

Параметры:

<OBJECT> - AMQP-объект.

Пример:

admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/list         
┌─┬────────────┬──────┐
│#│   Object   │Number│
├─┼────────────┼──────┤
│1│Session     │238   │
│2│Queue       │399   │
│3│Subscription│754   │
│4│Exchange    │25    │
│5│Binding     │569   │
│6│Connections │168   │
│7│Nodes       │2     │
└─┴────────────┴──────┘

[exec at: 05.02.2019 22:57:21, exec time: 91ms, nodes: mycelium1@ecss1]

ping

Команда измерения латентности взаимодействия с AMQP-брокером.

Путь команды:

/cluster/bus/<NODE@CLUSTER>/ping

Синтаксис:

ping [<TestNum> [<Timeout>]]

Параметры:

<TestNum> - количество ping-запросов;
<Timeout> - время между отправкой повторных ping-запросов.

Пример:

admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/ping 4
total=1595 net=1061 route=9 qu=48 session=477
total=1288 net=852 route=6 qu=22 session=408
total=1304 net=830 route=6 qu=82 session=386
total=7664 net=823 route=6 qu=23 session=6812

--- ping statistics ---
4 messages transmitted, 4 messages received, 0 messages loss
avarage: total=2962 net=891 route=6 qu=43 session=2020

[exec at: 05.02.2019 22:26:39, exec time: 4s 84ms, nodes: mycelium1@ecss1]

reset_stat

Команда для сброса статистики AMQP-объекта на брокере.

Путь команды:

/cluster/bus/<CLUSTER>/reset_stat [--force]

Синтаксис:

reset_stat <QUEUE> where <WHERE_CONDITION>

Параметры:

<QUEUE> - имя очереди;
<WHERE_CONDITION> - условия отбора записи;

--force - выполнение команды без запроса подтверждения.

Пример:

admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/reset_stat queue where pid = 1628         
[reset_stat] You are going reset statistic data to 1 queue(s) forever.
              
             Selected queues:
               ccn.group.ecss_cm.68270355E388B6D65ED8B13B7F4274D4
              
Are you sure?: [n]/y ?> y
One object has been reset

[exec at: 05.02.2019 22:45:04, exec time: 5s 624ms, nodes: mycelium1@ecss1]

show

Команда просмотра параметров AMQP-объекта на брокере.

Путь команды:

/cluster/bus/<CLUSTER>/show

Синтаксис:

show message <Qu> <MsgId> - просмотр информации об определенном сообщении в очереди;

show rejected <Node>/<MsgId> - просмотр информации об определенном сообщении, которое было отклонено;

show queue <Qu> - просмотр информации об определенной очереди;

show dropped <Node>/<MsgId> - просмотр информации об определенном сообщении, которое было потеряно;

show queue_info <Qu> - Print info about specified queue

Параметры:

<Qu> - очередь AMQP;
<MsgId> - идентификатор сообщения;
<Node> - имя ноды.

Пример:

Информация об отклоненном сообщении:

admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/show rejected mycelium1@ecss1/0
┌─────────┬──────────────────────────────────────────────────────────────────────────────┐
│   Key   │                                    Value                                     │
├─────────┼──────────────────────────────────────────────────────────────────────────────┤
│Id       │mycelium1@ecss1/0                                                             │
│Time     │05.02.2019 21:50:45                                                           │
│Reason   │rejected                                                                      │
│From     │<<"dds.bus.7.sip1.ecss1">>                                                    │
│Cmd      │{'message.transfer',<<"ecss.storage.ex">>,0,0}                                │
│Headers  │{'message.transfer_header',                                                   │
│         │    {'message.delivery_properties',false,false,false,4,1,5000,undefined,      │
│         │        undefined,undefined,<<"ecss.storage.req">>,undefined,undefined},      │
│         │    undefined,                                                                │
│         │    {'message.message_properties',undefined,undefined,undefined,              │
│         │        {'message.reply_to',<<"ecss.storage.ex">>,<<"dds.bus.7.sip1.ecss1">>},│
│         │        undefined,undefined,undefined,undefined,undefined}}                   │
│Body size│143B                                                                          │
│Body     │[{'rtop-req',rtop_cluster,cluster_by_node,                                    │
│         │             [sip1@ecss1,adapter],                                            │
│         │             5000,                                                            │
│         │             {<41737.2293.0>,#Ref<41737.1289111833.3967025154.27639>},        │
│         │             0}]                                                              │
└─────────┴──────────────────────────────────────────────────────────────────────────────┘

[exec at: 05.02.2019 22:28:55, exec time: 58ms, nodes: mycelium1@ecss1]

Информация об очереди:

admin@[mycelium1@ecss1]:/$ cluster/bus/amqp2/show queue_info acp.core.core1.0.init.q 
Name                           acp.core.core1.0.init.q
Alternate exchange             acp.core.init.alt.ex
Durable                        no
Exclusive                      no
Exclusive owner                -
Auto delete                    no
Pid                            <41399.2026.0>
drop_type                      drop arrived message
Warning on overlow             yes
shuffle_subs                   no
GC period (ms)                 never
Lifetime interval (ms)         1000
Maximum possible depth         1000
QDepth current/max             0/0
MDepth current/max             0/1
Subscription number            16
Messages in/out                3/3
drop_num                       0
incoming_traffic               1687
total_traffic                  0
Message per second current/max 0/0
Acceptance time                0
Maximum acceptance time        0
Uptime                         0d 00:42:03

[exec at: 05.02.2019 22:33:32, exec time: 66ms, nodes: mycelium1@ecss1]