RabbitMQ Module

Table of Contents

1. Admin Guide
1.1. Overview
1.2. Dependencies
1.2.1. OpenSIPS Modules
1.2.2. External Libraries or Applications
1.3. Exported Parameters
1.3.1. server_id (string)
1.3.2. use_tls (integer)
1.4. Exported Functions
1.4.1. rabbitmq_publish(server_id, routing_key, message [, [content_type [, headers, headers_vals]]])
2. Contributors
2.1. By Commit Statistics
2.2. By Commit Activity
3. Documentation
3.1. Contributors

List of Tables

2.1. Top contributors by DevScore(1), authored commits(2) and lines added/removed(3)
2.2. Most recently active contributors(1) to this module

List of Examples

1.1. Set server_id parameter
1.2. Set the use_tls parameter
1.3. rabbitmq_publish() function usage

Chapter1.Admin Guide


RabbitMQ (http://www.rabbitmq.com/) is an open source messaging server. It's purpose is to manage received messages in queues, taking advantage of the flexible AMQP protocol.

Using this module you can send AMQP messages to a RabbitMQ server. Messages can be easily customized according to the AMQP specifications, as well the RabbitMQ extensions.


1.2.1.OpenSIPS Modules

The following modules must be loaded before this module:

1.2.2.External Libraries or Applications

The following libraries or applications must be installed before running OpenSIPS with this module loaded:

  • librabbitmq-dev

1.3.Exported Parameters

1.3.1.server_id (string)

Specify configuration for a RabbitMQ server. It contains a set of parameters used to customize the connection to the server, as well as to the messages sent. The format of the parameter is [id_name] param1=value1; param2=value2;. The uri parameter is mandatory.

This parameter can be set multiple times, for each RabbitMQ server.

The following parameters can be used:

  • uri - Mandatory parameter - a full amqp URI as described here. Missing fields in the URI will receive default values, such as: user: guest, password: guest, host: localhost, vhost: /, port: 5672. TLS connections are specified using an amqps URI.

  • frames - the maximum size of an AMQP frame. Optional parameter, default size is 131072.

  • retries - the number of retries in case a connection is down. Optional parameter, default is disabled (do not retry).

  • exchange - exchange used to send AMQP messages to. Optional parameter, default is "".

  • heartbeat - interval in seconds used to send heartbeat messages. Optional parameter, default is disabled.

  • immediate - indicate to the broker that the message MUST be delivered to a consumer immediately. Optional parameter, default is not immediate.

  • mandatory - indicate to the broker that the message MUST be routed to a queue. Optional parameter, default is not mandatory.

  • non-persistent - indicates that the message should not be persistent in case the RabbitMQ server restarts. Optional parameter, default is persistent.

  • tls_domain - indicates which TLS domain (as defined using the tls_mgm module) to use for this connection. This must be an amqps URI and the use_tls module parameter must be enabled.

Example1.1.Set server_id parameter

# connection to a RabbitMQ server on localhost, default port
modparam("rabbitmq", "server_id","[ID1] uri = amqp://")
# connection with a 5 seconds interval for heartbeat messages
modparam("rabbitmq", "server_id","[ID2] uri = amqp://;
heartbeat = 5")
# TLS connection
modparam("rabbitmq", "server_id","[ID3] uri = amqps://; tls_domain=rmq")

1.3.2.use_tls (integer)

Setting this parameter will allow you to use TLS for broker connections. In order to enable TLS for a specific connection, you can use the "tls_domain=dom_name" parameter in the configuration specified through the server_id module parameter.

When using this parameter, you must also ensure that tls_mgm is loaded and properly configured. Refer to the the module for additional info regarding TLS client domains.

Default value is 0 (not enabled)

Example1.2.Set the use_tls parameter

modparam("tls_mgm", "client_domain", "rmq")
modparam("tls_mgm", "certificate", "[rmq]/etc/pki/tls/certs/rmq.pem")
modparam("tls_mgm", "private_key", "[rmq]/etc/pki/tls/private/rmq.key")
modparam("tls_mgm", "ca_list",     "[rmq]/etc/pki/tls/certs/ca.pem")
modparam("rabbitmq", "use_tls", 1)

1.4.Exported Functions

1.4.1. rabbitmq_publish(server_id, routing_key, message [, [content_type [, headers, headers_vals]]])

Sends a publish message to a RabbitMQ server.

This function also allows you to attach AMQP headers and values in the AMQP message. This is done by specifying a set of headers names (in the headers parameter) and the corresponding values (in the headers_vals parameter). The number of AVP values in the headers must be the same as the one in the headers_vals.

This function can be used from any route.

The function has the following parameters:

  • server_id (string) - the id of the RabbitMQ server. Must be one of the parameters defined in the server_id modparam.

  • routing_key (string) - routing key used to deliver the AMQP message.

  • message (string) - the body of the message.

  • content_type (string, optional) - content type of the message sent. By default it is none.

  • headers (string, optional) - an AVP containing the names of the headers within the AMQP message. If set, headers_vals parameter must also be specified.

  • headers_vals (string, optional) - an AVP containing the corresponding values of the AMQP headers. If set, headers parameter must also be specified.

Example1.3.rabbitmq_publish() function usage

	rabbitmq_publish("ID1", "call", "$fU called $rU");
	rabbitmq_publish("ID1", "call", "{ \'caller\': \'$fU\',
					\'callee\; \'$rU\'", "application/json");
	$avp(hdr_name) = "caller";
	$avp(hdr_value) = $fU;
	$avp(hdr_name) = "callee";
	$avp(hdr_value) = $rU;
	rabbitmq_publish("ID2", "call", $rb, , $avp(hdr_name), $avp(hdr_value));


2.1.By Commit Statistics

Table2.1.Top contributors by DevScore(1), authored commits(2) and lines added/removed(3)

NameDevScoreCommitsLines ++Lines --
1. Razvan Crainea (@razvancrainea)45301489112
2. Vlad Patrascu (@rvlad-patrascu)168540146
3. Liviu Chircu (@liviuchircu)751735
4. Maksym Sobolyev (@sobomax)4233
5. Bogdan-Andrei Iancu (@bogdan-iancu)3121
6. Walter Doekes (@wdoekes)3111

(1) DevScore = author_commits + author_lines_added / (project_lines_added / project_commits) + author_lines_deleted / (project_lines_deleted / project_commits)

(2) including any documentation-related commits, excluding merge commits. Regarding imported patches/code, we do our best to count the work on behalf of the proper owner, as per the "fix_authors" and "mod_renames" arrays in opensips/doc/build-contrib.sh. If you identify any patches/commits which do not get properly attributed to you, please submit a pull request which extends "fix_authors" and/or "mod_renames".

(3) ignoring whitespace edits, renamed files and auto-generated files

2.2.By Commit Activity

Table2.2.Most recently active contributors(1) to this module

NameCommit Activity
1. Vlad Patrascu (@rvlad-patrascu)May 2017 - May 2021
2. Maksym Sobolyev (@sobomax)Jul 2017 - Oct 2020
3. Razvan Crainea (@razvancrainea)Jan 2017 - Jul 2020
4. Walter Doekes (@wdoekes)Apr 2019 - Apr 2019
5. Bogdan-Andrei Iancu (@bogdan-iancu)Apr 2019 - Apr 2019
6. Liviu Chircu (@liviuchircu)Apr 2018 - Aug 2018

(1) including any documentation-related commits, excluding merge commits



Last edited by: Vlad Patrascu (@rvlad-patrascu), Liviu Chircu (@liviuchircu), Razvan Crainea (@razvancrainea).

Documentation Copyrights:

Copyright 2017 www.opensips-solutions.com