class LogStash::Inputs::Facebook
Generate a repeating message.
This plugin is intented only as an example.
Public Instance Methods
register()
click to toggle source
# File lib/logstash/inputs/facebook.rb, line 32 def register @api = Koala::Facebook::API.new(@oauth_token) end
run(queue)
click to toggle source
# File lib/logstash/inputs/facebook.rb, line 36 def run(queue) # we can abort the loop if stop? becomes true while !stop? feed = @api.get_connections(@facebook_id, "feed" , { limit: 10, fields: @fields }) feed.each do |p| event = LogStash::Event.new(p) decorate(event) queue << event end # because the sleep interval can be big, when shutdown happens # we want to be able to abort the sleep # Stud.stoppable_sleep will frequently evaluate the given block # and abort the sleep(@interval) if the return value is true Stud.stoppable_sleep(@interval) { stop? } end # loop end
stop()
click to toggle source
# File lib/logstash/inputs/facebook.rb, line 54 def stop # nothing to do in this case so it is not necessary to define stop # examples of common "stop" tasks: # * close sockets (unblocking blocking reads/accepts) # * cleanup temporary files # * terminate spawned threads end