Class: LogStash::Inputs::RabbitMQ

Inherits:

Threadable

• Object
• Plugin
• Base
• Threadable
• LogStash::Inputs::RabbitMQ

Includes:

BunnyImpl, MarchHareImpl

Defined in:

lib/logstash/inputs/rabbitmq.rb,
lib/logstash/inputs/rabbitmq/bunny.rb,
lib/logstash/inputs/rabbitmq/march_hare.rb

Overview

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>

Direct Known Subclasses

Zenoss

Defined Under Namespace

Modules: BunnyImpl, MarchHareImpl

Constant Summary

Constants included from Config::Mixin

Config::Mixin::CONFIGSORT

Instance Attribute Summary

Attributes inherited from Base

#params, #threadable

Attributes included from Config::Mixin

#config, #original_params

Attributes inherited from Plugin

#logger, #params

Instance Method Summary

• #initialize(params) ⇒ RabbitMQ constructor

  A new instance of RabbitMQ.

Methods included from BunnyImpl

#consume, #register, #run, #setup, #teardown

Methods included from MarchHareImpl

#register, #run, #teardown

Methods inherited from Base

#register, #tag

Methods included from Config::Mixin

#config_init, included

Methods inherited from Plugin

#eql?, #finished, #finished?, #hash, #inspect, lookup, #reload, #running?, #shutdown, #teardown, #terminating?, #to_s

Constructor Details

#initialize(params) ⇒ RabbitMQ

Returns a new instance of RabbitMQ.

# File 'lib/logstash/inputs/rabbitmq.rb', line 104

def initialize(params)
  params["codec"] = "json" if !params["codec"]

  super
end