User Tools

Site Tools


data_core:rabbitmq

This is an old revision of the document!


RabbitMQ

RabbitMQ is a popular open source message broker. In a process data context, it can be used for buffering and/or routing data across networks and between servers.

Data Core supports this with two components:

  • Rabbit MQ Producer - Writes process data to a queue
  • Rabbit MQ Consumer - Reads process data from a queue

Getting Started

Enable RabbitMQ on Windows

RabbitMQ has several deployment options - below we provide our recommended approach.

1. Install Erlang

Erlang is a high-level programming language for real-time systems. It is a pre-requisite of RabbitMQ.

Download and run the Erlang 64bit Windows Installer.

2. Install RabbitMQ

Download and run the RabbitMQ 64bit Windows Installer.

3. Enable RabbitMQ Admin UI

Open RabbitMQ Command Prompt in admin mode and enter

rabbitmq-plugins enable rabbitmq_management 

4. Enable Shovel Plugin (optional)

The shovel plugin is only required on servers actively pushing data downstream to another server.

Open RabbitMQ Command Prompt in admin mode and enter

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

5. Restart RabbitMQ Server

Open Windows Services and restart the “RabbitMQ” service.

RabbitMQ Administration

The RabbitMQ Admin UI is accessible on

http://localhost:15672/

Hint 8-): Bookmark this link.

The default login is Guest/Guest.
This account account is only permitted for localhost login. Also note port 15672 is closed by default.

RabbitMQ Producer

RabittMQ Producer writes tag-value data to a queue.

The default configuration writes persistent messages to a local, durable queue called “data_core.tag_values”. This means messages are stored to the hard drive and will survive a server restart.

The keys settings are:

  • Routing Key
    The routing key to set on messages containing snapshot/historical tag values.

RabbitMQ Consumer

RabittMQ Consumer reads tag-value data from a queue.

The default configuration reads messages from a local queue called “data_core.tag_values”. The driver will create this queue if it doesn't already exist.

The keys settings are:

  • Queue Names
    A comma-delimited list of RabbitMQ queues to read tag values and/or event messages from.

How to use RabbitMQ for Secure Resilient Data Transfer

RabbitMQ supports server to server message transfer via the plugin RabbitMQ Shovel.

  • Messages are not removed from the source queue until an ack is received from the destination queue.
  • It supports TLS data encryption.

Altogether, RabbitMQ provides the ideal conduit for Data Core to employ for resilient and secure process data transfer.

1. Enable RabbitMQ Shovel

RabbitMQ Shovel is a required on the source/upstream RabbitMQ server.

Open RabbitMQ Command Prompt in admin mode and enter

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

2. Restart RabbitMQ Server

Open Windows Services and restart the “RabbitMQ” service.

data_core/rabbitmq.1678899649.txt.gz · Last modified: 2023/03/15 17:00 by su