The SimpleOne system can be configured as a consumer application that can accept messages from third-party services through a connection to the RabbitMQ message broker.

RabbitMQ acts as an intermediary to route messages from the external application to specific queues where the messages are stored until they are delivered to the consumer.

To connect to a specific RabbitMQ queue, create a consumer entry in the system. To do this, complete the following steps:

  1. Navigate to External Queues → RabbitMQ Consumers.
  2. Click New and fill in the fields.
  3. Click Save or Save and Exit.

RabbitMQ Consumer form fields

Field

Mandatory 

Description

Name

Y

Specify a consumer name.

ActiveNSelect the checkbox to activate the consumer record.
Enable debugNSelect the checkbox to have advanced logs. Use them to identify problems when configuring consumer settings.

Host name

Y

Enter a RabbitMQ host name to connect to in the example.com format.

Port

Y

Specify the server connection port.

Virtual host

N

Specify the host designated in the RabbitMQ server settings.

Queue nameYSpecify the name of the queue that you need to receive the messages from.

Username

Y

Specify a user login for the RabbitMQ server connection.

Password

Y

Specify a user password for the RabbitMQ server connection.

Connection time out

N

Set the RabbitMQ server connection time out.

Run as userYSelect the user on whose behalf the script will be executed.
ScriptY

Enter a script that will process received messages and invoke certain actions in the system. The following variables are available in the script:

body of type string – the message sent to the queue.
headers of type object – a set of string keys with string values passed in message headers.

Example
(function(body, headers) {
    ss.info(body + JSON.stringify(headers));
})(body, headers)

The consumer does not create queues, it connects only to existing ones. After establishing a connection to the RabbitMQ server, the target queue may be empty. Messages are only delivered when there are new messages in the queue.

Unloading and processing messages do not happen at the same time. The message is read from the outer queue and enters the inner queue, where it waits for its turn to be processed.

If the connection to the server is lost, the consumer attempts to restore connection. The time between attempts is determined by the Connection time out field and is 30 seconds by default. The maximum number of failed attempts is determined by the message broker's settings.


  • No labels

© 2019-2023, SimpleOne

https://simpleone.ru