class Fluent::YammerOutput
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_yammer.rb, line 8 def initialize super require 'yammer' end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_yammer.rb, line 13 def configure(conf) super @yammer = Yammer::Client.new(:access_token => conf['access_token']) @group_id = conf['group_id'] end
create_message(message)
click to toggle source
# File lib/fluent/plugin/out_yammer.rb, line 27 def create_message(message) @yammer.create_message(message, :group_id => @group_id) rescue Yammer::Error => e $log.error("Yammer Error: #{e.message}") end
emit(tag, es, chain)
click to toggle source
# File lib/fluent/plugin/out_yammer.rb, line 19 def emit(tag, es, chain) es.each do |time, record| create_message(record['message']) end chain.next end