This module offers amqp communication using librabbitmq. This module was created using rabbitmq-c C client (https://github.com/alanxz/rabbitmq-c). A new amqp connection is set up on a per-children basis, when Kamailio starts. If connection is lost, the process tries to re-establish it when a new amqp action is required. Currently librabbitmq offers no async API, but sync API, with a timeout. See below link for updates on this issue: * https://github.com/alanxz/rabbitmq-c/issues/370.
| Parámetro | Tipo | Descripción |
|---|---|---|
| url | string | 3.2. timeout_sec (int) 3.3. timeout_usec (int) 3.4. direct_reply_to (int) |
| timeout_sec | int | 3.3. timeout_usec (int) 3.4. direct_reply_to (int) |
| timeout_usec | int | 3.4. direct_reply_to (int) |
| direct_reply_to | int | 3.1. url (string) |
| url | string | The amqp connection url. |
| timeout_sec | int | The timeout in seconds. The timeout_sec + timeout_usec combination gives the time to wait for an amqp reply, when rabbitmq_publish_consume() is used. |
| timeout_usec | int | The timeout in micro seconds. The timeout_sec + timeout_usec combination gives the time to wait for an amqp reply, when rabbitmq_publish_consume() is used. |
| direct_reply_to | int | Setting this parameter to 1, enables rabbitmq direct reply-to feature. More info about this, can be found at https://www.rabbitmq.com/direct-reply-to.html. |
4.2. rabbitmq_publish_consume(exchange, routing_key, content_type, messagebody, reply)
4.1. rabbitmq_publish(exchange, routing_key, content_type, messagebody)
The function publishes messagebody without waiting for a reply.
The function publishes messagebody and waits timeoute_sec + timeout_usec for a reply. If the reply comes, one can read it in the reply avp.
Copyright © 2016 ONEm Communications Ltd.
