From 1213d77d947145e7ee66c30a8cae62ae1ca1a23e Mon Sep 17 00:00:00 2001 From: Jordan Sissel Date: Thu, 11 Nov 2010 09:02:35 +0000 Subject: [PATCH] forgot to check this in (fixes queue naming) --- lib/logstash/inputs/amqp.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/logstash/inputs/amqp.rb b/lib/logstash/inputs/amqp.rb index a92f47197..b1751874b 100644 --- a/lib/logstash/inputs/amqp.rb +++ b/lib/logstash/inputs/amqp.rb @@ -31,11 +31,11 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base case @mqtype when "fanout" #@target.bind(MQ.fanout(@url.path, :durable => true)) - @target.bind(MQ.fanout(@url.path)) + @target.bind(MQ.fanout(@name)) when "direct" - @target.bind(MQ.direct(@url.path)) + @target.bind(MQ.direct(@name)) when "topic" - @target.bind(MQ.topic(@url.path)) + @target.bind(MQ.topic(@name)) end # case @mqtype @target.subscribe(:ack => true) do |header, message|