class ElasticAPM::Worker

def process(item)
  @adapter.post(item.path, item.payload)
rescue ::Exception => e
  fatal 'Failed posting: %s', e.inspect
  debug e.backtrace.join("\n")
  nil
end