class ElasticAPM::Transport::Worker

def process(resource)
  return unless (json = serialize_and_filter(resource))
  connection.write(json)
end