Skip to content

Latest commit

 

History

History
50 lines (42 loc) · 1.72 KB

amqp.md

File metadata and controls

50 lines (42 loc) · 1.72 KB
Raw

AMQP input plugin

Status : core plugin, unit tested and maintained.

This plugin is used to get logs from an AMQP exchange, like a RabbitMQ exchange. This plugin is compatible with the original AMQP logstash plugin.

Example 1: Fanout mode: Receive message from fanout exchange toto Config using url: input://amqp://localhost:5672?exchange_name=toto

Config using logstash format:

input {
  amqp {
    host => localhost
    port => 5672
    exchange_name => toto
  }
}

Example 2: Topic mode: Receive message from topic test on exchange toto_topic Config using url: input://amqp://localhost:5672?exchange_name=toto_topic&topic=test

Config using logstash format:

input {
  amqp {
    host => localhost
    port => 5672
    exchange_name => toto_topic
    topic => test
  }
}

Parameters:

  • host: ip of the AMQP broker.
  • port: port of the AMQP broker.
  • topic: topic to use in topic mode. Default : none, fanout mode is used.
  • durable: set exchange durability. Default : true.
  • retry_delay: retry delay (in ms) to connect AMQP broker. Default : 3000.
  • heartbeat: AMQP heartbeat in s. Default: 10
  • type: to specify the log type, to faciliate crawling in kibana. Example: type=rabbit. No default value.
  • username: username for PLAIN authentication to amqp broker. No default value.
  • password: password for PLAIN authentication to amqp broker. No default value.
  • vhost: amqp vhost to use. No default value.
  • ssl: enable SSL mode. More doc at ssl. Default : false
  • unserializer: more doc at unserializers. Default value to json_logstash.