For other versions, see theVersioned plugin docs.
For questions about the plugin, open a topic in the Discuss forums. For bugs or feature requests, open an issue in Github.For the list of Elastic supported plugins, please consult the Elastic Support Matrix.
Push events to a RabbitMQ exchange. Requires RabbitMQ 2.xor later version (3.x is recommended).
Relevant links:
This plugin supports the following configuration options plus the Common Options described later.
| Setting | Input type | Required |
|---|---|---|
No |
||
No |
||
No |
||
No |
||
No |
||
Yes |
||
string, one of |
Yes |
|
No |
||
Yes |
||
No |
||
No |
||
No |
||
No |
||
No |
||
No |
||
No |
||
No |
||
a valid filesystem path |
No |
|
No |
||
No |
||
No |
Also see Common Options for a list of options supported by alloutput plugins.
{}Extra queue arguments as an array.To make a RabbitMQ queue mirrored, use: {"x-ha-policy" => "all"}
trueSet this to automatically recover from a broken connection. You almost certainly don’t want to override this!!!
1Time in seconds to wait before retrying a connection
The default connection timeout in milliseconds. If not specified the timeout is infinite.
trueIs this exchange durable? (aka; Should it survive a broker restart?)
The name of the exchange
fanout, direct, topic, x-consistent-hash, x-modulus-hashThe exchange type (fanout, topic, direct)
Heartbeat delay in seconds. If unspecified no heartbeats will be sent
Common functionality for the rabbitmq input/outputRabbitMQ server address(es)host can either be a single host, or a list of hostsi.e. host ⇒ "localhost"or host ⇒ ["host01", "host02]
if multiple hosts are provided on the initial connection and any subsequentrecovery attempts of the hosts is chosen at random and connected to.Note that only one host connection is active at a time.
"logstash"The default codec for this plugin is JSON. You can override this to suit your particular needs however.Key to route to by default. Defaults to logstash
{}Add properties to be set per-message here, such as Content-Type, Priority
Example:
message_properties => { "priority" => "1" }
falsePassive queue creation? Useful for checking queue existance without modifying server state
Enable or disable SSL.Note that by default remote certificate verification is off.Specify ssl_certificate_path and ssl_certificate_password if you needcertificate verification
Password for the encrypted PKCS12 (.p12) certificate file specified in ssl_certificate_path
Path to an SSL certificate in PKCS12 (.p12) format used for verifying the remote host
"/"The vhost (virtual host) to use. If you don’t know what thisis, leave the default. With the exception of the defaultvhost ("/"), names of vhosts should not begin with a forwardslash.
The following configuration options are supported by all output plugins:
"json"The codec used for output data. Output codecs are a convenient method for encoding your data before it leaves the output without needing a separate filter in your Logstash pipeline.
trueDisable or enable metric logging for this specific plugin instance.By default we record all the metrics we can, but you can disable metrics collectionfor a specific plugin.
Add a unique ID to the plugin configuration. If no ID is specified, Logstash will generate one.It is strongly recommended to set this ID in your configuration. This is particularly usefulwhen you have two or more plugins of the same type. For example, if you have 2 rabbitmq outputs.Adding a named ID in this case will help in monitoring Logstash when using the monitoring APIs.
output { rabbitmq { id => "my_plugin_id" }}