github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

- use 'direct' for exchange type, not 'queue'

Browse source
This commit is contained in:
Jordan Sissel 2011-02-27 23:23:51 -08:00
parent 7415a9c445
commit d159e408b0
2 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

3
lib/logstash/inputs/amqp.rb
View file

@ -3,7 +3,7 @@ require "logstash/inputs/base"
require "logstash/namespace"
class LogStash::Inputs::Amqp < LogStash::Inputs::Base
MQTYPES = [ "fanout", "queue", "topic" ]
MQTYPES = [ "fanout", "direct", "topic" ]
config_name "amqp"
@ -16,7 +16,6 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
config :durable, :validate => :boolean
config :debug, :validate => :boolean
public
def initialize(params)
super

4
lib/logstash/outputs/amqp.rb
View file

@ -3,7 +3,7 @@ require "logstash/outputs/base"
require "logstash/namespace"
class LogStash::Outputs::Amqp < LogStash::Outputs::Base
MQTYPES = [ "fanout", "queue", "topic" ]
MQTYPES = [ "fanout", "direct", "topic" ]
config_name "amqp"
config :host, :validate => :string
@ -46,7 +46,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
case @exchange_type
when "fanout"
@target = @bunny.exchange(@name, :type => :fanout)
when "queue"
when "direct"
@target = @bunny.exchange(@name, :type => :direct)
when "topic"
@target = @bunny.exchange(@name, :type => :topic)