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:

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