AMQP output plugin for Fluentd

Fluentd output plugin to publish events to an amqp broker.

Events are published one by one using the Fluentd tag as the routing key, in JSON format like:

{ "key": "fluentd-tag", "timestamp": "fluentd-timestamp", "payload": "event-payload" }

Installation

Add this line to your application's Gemfile:

gem 'fluent-plugin-amqp2'

And then execute:

$ bundle

Or install it yourself as:

$ gem install fluent-plugin-amqp2

Configuration

<match pattern>
  type amqp

  # Set broker host and port
  host localhost
  port 5672

  # Set user and password for authentication
  user guest
  password guest

  # Configure amqp entities vhost, exchange id and type
  vhost /
  exchange my_exchange
  exchange_type topic
</match>

Contributing

  1. Fork it
  2. Create your feature branch (git checkout -b my-new-feature)
  3. Commit your changes (git commit -am 'Add some feature')
  4. Push to the branch (git push origin my-new-feature)
  5. Create new Pull Request