rss.rb in logstash-input-rss-2.0.3

- old
+ new

@@ -38,11 +38,11 @@
       start = Time.now
       @logger.info? && @logger.info("Polling RSS", :url => @url)
 
       # Pull down the RSS feed using FTW so we can make use of future cache functions
       response = Faraday.get @url
-      handle_response(response)
+      handle_response(response, queue)
 
       duration = Time.now - start
       @logger.info? && @logger.info("Command completed", :command => @command,
                                     :duration => duration)
 
@@ -57,10 +57,10 @@
         Stud.stoppable_sleep(sleeptime) { stop? }
       end
     end # loop
   end
 
-  def handle_response(response)
+  def handle_response(response, queue)
     body = response.body
     # @logger.debug("Body", :body => body)
     # Parse the RSS feed
     feed = RSS::Parser.parse(body)
     feed.items.each do |item|