lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.1 vs lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.2

@@ -5,13 +5,14 @@
 class LogStash::Inputs::Nsq < LogStash::Inputs::Base
   config_name 'nsq'
 
   default :codec, 'json'
 
-  config :nsqlookupd, :validate => :string, :default => 'localhost:4161'
+  config :nsqlookupd, :validate => :array, :default => 'localhost:4161'
   config :channel, :validate => :string, :default => 'logstash'
   config :topic, :validate => :string, :default => 'testtopic'
+  config :max_in_flight, :validate => :number, :default => 100
 
 
   public
   def register
    @logger.info('Registering nsq', :channel => @channel, :topic => @topic, :nsqlookupd => @nsqlookupd)
@@ -23,10 +24,11 @@
     begin
       begin
         consumer = Nsq::Consumer.new(
            :nsqlookupd => @nsqlookupd,
            :topic => @topic,
-           :channel => @channel
+           :channel => @channel,
+           :max_in_flight => @max_in_flight
         )
         while true
           #@logger.info('consuming...')
           event = consumer.pop
           #@logger.info('processing:', :event => event)