Supports multiple groups of metrics. For more information on AMQP protocol please visit RabbitMQ tutorial.
connect(host = "127.0.0.1")
Supported parameters: host, port, username, and password. By default username and password are "guest".
declare_queue("q1")
Queue needs to be declared before publish or get.
declare_exchange("x1")
bind("x1", "key1", "q1")
Binds specific key for an exchange to a queue.
publish("q1", "message")
or
publish("x1", "key1", "message")
Publish specific message to a queue or a key and exchange.
get("q1")
Read specific queue and return control.
subscribe("q1")
Spawn additional thread and subscribe to a queue.
Set prefix for metric reporting, for example you could differ between two queries or two threads stats.
set_prefix("mygroup")