class LogStash::Inputs::RabbitMQ
Pull events from a RabbitMQ
exchange.
The default settings will create an entirely transient queue and listen for all messages by default. If you need durability or any other advanced settings, please set the appropriate options
This has been tested with Bunny 0.9.x, which supports RabbitMQ
2.x and 3.x. You can find links to both here:
-
RabbitMQ
- <www.rabbitmq.com/> -
March Hare: <rubymarchhare.info>
-
Bunny - <github.com/ruby-amqp/bunny>
Public Class Methods
new(params)
click to toggle source
Calls superclass method
LogStash::Inputs::Threadable::new
# File lib/logstash/inputs/rabbitmq.rb, line 104 def initialize(params) params["codec"] = "json" if !params["codec"] super end