class ElasticAPM::Transport::Worker

def process(resource)
  serialized = serializers.serialize(resource)
  @filters.apply!(serialized)
  @connection.write(serialized.to_json)
end