Class: LogStash::Outputs::RabbitMQ

Inherits:

Base

• Object
• Plugin
• Base
• LogStash::Outputs::RabbitMQ

Includes:

BunnyImpl, MarchHareImpl

Defined in:

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

Overview

Push events to a RabbitMQ exchange. Requires RabbitMQ 2.x or later version (3.x is recommended).

Relevant links:

• RabbitMQ: <www.rabbitmq.com/>

• March Hare: <rubymarchhare.info>

• Bunny: <rubybunny.info>

Defined Under Namespace

Modules: BunnyImpl, MarchHareImpl

Constant Summary

EXCHANGE_TYPES =

["fanout", "direct", "topic"]

Constants included from Config::Mixin

Config::Mixin::CONFIGSORT

Instance Attribute Summary

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

#connect, #declare_exchange, #publish_serialized, #receive, #register, #teardown, #to_s

Methods included from MarchHareImpl

#connect, #declare_exchange, #publish_serialized, #receive, #register, #teardown, #to_s

Methods inherited from Base

#handle, #handle_worker, #receive, #register, #worker_setup, #workers_not_supported

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/outputs/rabbitmq.rb', line 74

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

  super
end