Skip to main content

Forwarding logs to 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:

PropertyValueComment
URLamqp://user:password@1.2.3.4:5672/flowgAdjust the URL according to your setup, the path correspond to the Virtual Host in which we created the exchange above
Exchangeflowg.defaultThis is the exchange we created above
Routing Keya.b.cYou can use any value you want actually
AMQP Forwarder Configuration

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

Pipeline with AMQP 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.