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

- Allow durable exchanges (https://logstash.jira.com/browse/LOGSTASH-37)

Browse source
This commit is contained in:
Jordan Sissel 2011-04-03 23:35:00 -07:00
parent 424aef4803
commit 9652044820
2 changed files with 2 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -48,7 +48,7 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
@bunny.start
@queue = @bunny.queue(@name)
exchange = @bunny.exchange(@name, :type => @exchange_type.to_sym)
exchange = @bunny.exchange(@name, :type => @exchange_type.to_sym, :durable => @durable)
@queue.bind(exchange)
end # def register

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

@ -42,15 +42,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
@bunny = Bunny.new(amqpsettings)
@bunny.start
@target = nil
case @exchange_type
when "fanout"
@target = @bunny.exchange(@name, :type => :fanout)
when "direct"
@target = @bunny.exchange(@name, :type => :direct)
when "topic"
@target = @bunny.exchange(@name, :type => :topic)
end # case @exchange_type
@target = @bunny.exchange9@name, :type => @exchange_type.to_sym, :durable => @durable)
end # def register
public