Class: LogStash::Outputs::RabbitMQ

Inherits:

Base

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

Includes:

BunnyImpl, MarchHareImpl

Defined in:

lib/logstash/outputs/rabbitmq.rb,
lib/logstash/outputs/rabbitmq/march_hare.rb,
lib/logstash/outputs/rabbitmq/bunny.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"]

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

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