class ElasticAPM::Subscriber

def start(name, id, payload)
  # debug "AS::Notification#start:#{name}:#{id}"
  return unless (transaction = @agent.current_transaction)
  normalized = @normalizers.normalize(transaction, name, payload)
  span =
    if normalized == :skip
      nil
    else
      name, type, context = normalized
      @agent.span(name, type, context: context)
    end
  transaction.notifications << Notification.new(id, span)
end