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 the same config names for password for amqp.

Browse source
This commit is contained in:
Jordan Sissel 2011-04-03 23:37:18 -07:00
parent 9652044820
commit 81f9cb9f32
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -10,7 +10,7 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
config :host, :validate => :string, :required => true
config :port, :validate => :number
config :user, :validate => :string, :required => true
config :pass, :validate => :string, :required => true
config :password, :validate => :string, :required => true
config :exchange_type, :validate => :string, :required => true
config :name, :validate => :string, :required => true
config :vhost, :validate => :string

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

@ -8,7 +8,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
config_name "amqp"
config :host, :validate => :string
config :user, :validate => :string
config :pass, :validate => :string
config :password, :validate => :string
config :exchange_type, :validate => :string
config :name, :validate => :string
config :vhost, :validate => :string
@ -36,7 +36,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
:port => (@port or 5672),
}
amqpsettings[:user] = @user if @user
amqpsettings[:pass] = @pass if @pass
amqpsettings[:pass] = @password if @password
amqpsettings[:logging] = @debug
@logger.debug(["Connecting to AMQP", amqpsettings, @exchange_type, @name])
@bunny = Bunny.new(amqpsettings)