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