Method: Fluent::Counter::Server#on_message

Defined in:
lib/fluent/counter/server.rb

#on_message(data) ⇒ Object 



68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/fluent/counter/server.rb', line 68

def on_message(data)
  errors = Validator.request(data)
  unless errors.empty?
    return { 'id' => data['id'], 'data' => [], 'errors' => errors }
  end

  result = safe_run do
    send(data['method'], data['params'], data['scope'], data['options'])
  end
  result.merge('id' => data['id'])
rescue => e
  @log.error e.to_s
end