Skip to main content

RabbitMQ

Introduction​

RabbitMQ is a reliable and mature messaging and streaming broker.

It supports the AMQP 0-9-1 protocol, which FlowG can use to send logs to RabbitMQ.

Setting up RabbitMQ​

You need to declare an exchange to receive logs. You can do this using the Management CLI:

rabbitmqadmin --vhost flowg declare exchange \
  --name "flowg.default" \
  --type "topic" \
  --durable "true"

Setting up the FlowG pipeline​

First, let's create an "AMQP Forwarder" named rabbitmq, with the following configuration:

Forwarder TypeAMQP
URLamqp://user:password@1.2.3.4:5672/flowg
?Adjust the URL to your setup. The path corresponds to the Virtual Host where the exchange was created.
Exchangeflowg.default
?The exchange created earlier.
Routing Keya.b.c
?You can use any value you want.

Then, create a pipeline that forwards logs to the rabbitmq forwarder:

And that's it!

What's next?​

Messages will be sent with the content-type application/json, you can then consume them using any AMQP client.