github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

- disable durable for now

Browse source
This commit is contained in:
Jordan Sissel 2010-10-18 08:17:58 +00:00
parent 0acb1d13f3
commit 240ff18dce
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -34,11 +34,12 @@ class LogStash::Inputs::Amqp
@target = @mq.queue(UUIDTools::UUID.timestamp_create)
case @type
when "fanout"
@target.bind(MQ.fanout(@url.path, :durable => true))
#@target.bind(MQ.fanout(@url.path, :durable => true))
@target.bind(MQ.fanout(@url.path))
when "direct"
@target.bind(MQ.direct(@url.path, :durable => true))
@target.bind(MQ.direct(@url.path))
when "topic"
@target.bind(MQ.topic(@url.path, :durable => true))
@target.bind(MQ.topic(@url.path))
end # case @type
@target.subscribe(:ack => true) do |header, message|