class ElasticAPM::Subscriber

def start(name, id, payload)
  return unless (transaction = @agent.current_transaction)
  normalized = @normalizers.normalize(transaction, name, payload)
  span =
    if normalized == :skip
      nil
    else
      name, type, subtype, action, context = normalized
      @agent.start_span(
        name,
        type,
        subtype: subtype,
        action: action,
        context: context
      )
    end
  transaction.notifications << Notification.new(id, span)
end