lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.5 vs lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.6
- old
+ new
@@ -31,11 +31,11 @@
:topic => @topic,
:channel => @channel,
:max_in_flight => @max_in_flight,
:tls_v1 => @tls_v1,
:tls_context => {
- key: @ssl_key,
- certificate: @ssl_cert
+ key: @tls_key,
+ certificate: @tls_cert
}
)
else
consumer = Nsq::Consumer.new(
:nsqlookupd => @nsqlookupd,