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

Add SSL configuration support for AMQP input and output plugins.

Browse source
This commit is contained in:
Christian Paredes 2011-07-29 14:06:33 -07:00
parent 1e73b37e51
commit 54fba32a73
2 changed files with 16 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -38,6 +38,12 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
# Enable or disable debugging
config :debug, :validate => :boolean, :default => false
# Enable or disable SSL
config :ssl, :validate => :boolean, :default => false
# Validate SSL certificate
config :verify_ssl, :validate => :boolean, :default => false
public
def initialize(params)
super
@ -63,6 +69,8 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
@amqpsettings[:user] = @user if @user
@amqpsettings[:pass] = @password.value if @password
@amqpsettings[:logging] = @debug
@amqpsettings[:ssl] = @ssl if @ssl
@amqpsettings[:verify_ssl] = @verify_ssl if @verify_ssl
@amqpurl = "amqp://"
if @user or @password
@amqpurl += "#{@user}:xxxxxx@"

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

@ -42,6 +42,12 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
# Enable or disable debugging
config :debug, :validate => :boolean, :default => false
# Enable or disable SSL
config :ssl, :validate => :boolean, :default => false
# Validate SSL certificate
config :verify_ssl, :validate => :boolean, :default => false
public
def register
require "bunny" # rubygem 'bunny'
@ -63,6 +69,8 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
}
amqpsettings[:user] = @user if @user
amqpsettings[:pass] = @password.value if @password
amqpsettings[:ssl] = @ssl if @ssl
amqpsettings[:verify_ssl] = @verify_ssl if @verify_ssl
begin
@logger.debug(["Connecting to AMQP", amqpsettings, @exchange_type, @name])