github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

forgot to check this in (fixes queue naming)

Browse source
This commit is contained in:
Jordan Sissel 2010-11-11 09:02:35 +00:00
parent 75910bb656
commit 1213d77d94
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -31,11 +31,11 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
case @mqtype case @mqtype
when "fanout" when "fanout"
#@target.bind(MQ.fanout(@url.path, :durable => true)) #@target.bind(MQ.fanout(@url.path, :durable => true))
@target.bind(MQ.fanout(@url.path)) @target.bind(MQ.fanout(@name))
when "direct" when "direct"
@target.bind(MQ.direct(@url.path)) @target.bind(MQ.direct(@name))
when "topic" when "topic"
@target.bind(MQ.topic(@url.path)) @target.bind(MQ.topic(@name))
end # case @mqtype end # case @mqtype
@target.subscribe(:ack => true) do |header, message| @target.subscribe(:ack => true) do |header, message|