LOGSTASH-2276 fixed if/else branch mixup in rabbitmq input

This commit is contained in:
Avishai Ish-Shalom 2014-08-07 08:38:51 +03:00
parent 6b20d179aa
commit 409dc8c366
2 changed files with 4 additions and 4 deletions

View file

@ -32,9 +32,9 @@ class LogStash::Inputs::RabbitMQ
@settings[:verify_ssl] = @verify_ssl if @verify_ssl
proto = if @ssl
"amqp"
else
"amqps"
else
"amqp"
end
@connection_url = "#{proto}://#{@user}@#{@host}:#{@port}#{vhost}/#{@queue}"

View file

@ -22,9 +22,9 @@ class LogStash::Inputs::RabbitMQ
@settings[:tls] = @ssl if @ssl
proto = if @ssl
"amqp"
else
"amqps"
else
"amqp"
end
@connection_url = "#{proto}://#{@user}@#{@host}:#{@port}#{vhost}/#{@queue}"