class Fluent::Counter::Client

def on_message(data)
  if response = @responses.delete(data['id'])
    response.set(data)
  else
    @log.warn("Receiving missing id data: #{data}")
  end
end