Собственно столкнулся с проблемой, что при использовании RabbitMQ необходимо мониторить сервер. Системную утилиту rabbitmqctl можно запускать из командной строки, но запустить ее из приложения не получилось. Что-то связанное с окружением эрланга.
После небольшого гугления и общения в целевых форумал получил заветную ссылку
Данный инструмент позволит автоматизировать администрирование сервера:
мониторинг и удаление старых очередей, связей и обменов и кол-во одновременных коннекций.
далее кр описание…
Сервер очередей RabbitMQ не имеет АПИ для его мониторинга и статистики. Модуль Alice позволяет осуществлять весь набор REST операций мониторинга:
/conn — Current connection information
/exchanges — Current exchanges information
/queues — Current queues
/users — Current users
/bindings — Current bindings
/control — Access to the RabbitMQ control
/permissions — Current permissions
/vhosts — Current vhosts
старт
Получить список пользователей
Получить список коннекций
Получить список обменов
Получить список очередей
Получить список связей
есть возможность управление сервером: start/stop
get/put данные в очередь но это я пока не использовал.
После небольшого гугления и общения в целевых форумал получил заветную ссылку
Данный инструмент позволит автоматизировать администрирование сервера:
мониторинг и удаление старых очередей, связей и обменов и кол-во одновременных коннекций.
далее кр описание…
Сервер очередей RabbitMQ не имеет АПИ для его мониторинга и статистики. Модуль Alice позволяет осуществлять весь набор REST операций мониторинга:
/conn — Current connection information
/exchanges — Current exchanges information
/queues — Current queues
/users — Current users
/bindings — Current bindings
/control — Access to the RabbitMQ control
/permissions — Current permissions
/vhosts — Current vhosts
старт
git clone git://github.com/auser/alice.git
cd alice
./start.sh
Получить список пользователей
# List users
curl -i localhost:9999/users
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 07:08:20 GMT
Content-Type: text/json
Content-Length: 19
{"users":["guest"]}
# Viewing a specific user
curl -i localhost:9999/users/guest
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 08:01:01 GMT
Content-Type: text/json
Content-Length: 17
{"users":"guest"}
Получить список коннекций
# List connections
curl -i localhost:9999/conn
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 07:30:52 GMT
Content-Type: text/json
Content-Length: 287
{"conn":[{"pid":"...","ip":"127.0.0.1","port":"5672","peer_address":"127.0.0.1" ...}]}
Получить список обменов
Exchanges
# List the current exchanges
curl -i localhost:9999/exchanges
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 07:34:14 GMT
Content-Type: text/json
Content-Length: 654
{"exchanges":[{"name":"amq.rabbitmq.log","type":"topic","durable":"true","auto_delete":...}
Получить список очередей
# List the current queues
curl -i localhost:9999/queues
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 07:35:42 GMT
Content-Type: text/json
Content-Length: 60
{"queues":[{"memory":"212988","name":"noises","vhost":"/"}]}
Получить список связей
# List the current bindings
curl -i localhost:9999/bindings
HTTP/1.1 200 OK
Server: MochiWeb/1.0 (Any of you quaids got a smint?)
Date: Tue, 04 Aug 2009 07:36:13 GMT
Content-Type: text/json
Content-Length: 69
{"bindings":[{"queue":"noises","exchange":"","from_queue":"noises"}]}
есть возможность управление сервером: start/stop
get/put данные в очередь но это я пока не использовал.