assertEquals("", problem.getSource());

        problem = new DefaultProblem(null, null, "", -1, -1, null);
        assertEquals("", problem.getSource());

        problem = new DefaultProblem(null, null, "SOURCE", -1, -1, null);
        assertEquals("SOURCE", problem.getSource());
    }

    @Test
    void testGetLocation() {

	opsID   string
}

// Lock - block until write lock is taken or timeout has occurred.
func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
	lockSource := getSource(2)
	start := UTCNow()

	newCtx, cancel := context.WithCancel(ctx)
	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
		Timeout:       timeout.Timeout(),

        Profile existing = profilesById.get(profileId);
        if (existing != null) {
            logger.warn("Overriding profile: '" + profileId + "' (source: " + existing.getSource()
                    + ") with new instance from source: " + profile.getSource());
        }

        profilesById.put(profile.getId(), profile);

        Activation activation = profile.getActivation();

        assertThrows(
            ConflictingRequirementsException.class, () -> buildTesterRequirements(Tester.class));
    assertThat(e.getConflicts()).containsExactly(FOO);
    assertThat(e.getSource()).isEqualTo(Tester.class.getAnnotation(Require.class));
  }

  public void testBuildTesterRequirements_classClassConflict_inherited() {
    @Require(FOO)
    abstract class BaseTester {}
    @Require(absent = FOO)

        if (inputLocation != null && inputLocation.getSource() != null) {
            StringBuilder stringBuilder = new StringBuilder();
            stringBuilder.append(inputLocation.getSource().getModelId());
            String location = inputLocation.getSource().getLocation();
            if (location != null) {
                if (location.contains("://")) {

        /**
         * The repositories specified in the request have precedence over the repositories declared in the POM.
         */
        REQUEST_DOMINANT,
    }

    @Nonnull
    ModelSource getSource();

    @Nonnull
    RequestType getRequestType();

    boolean isLocationTracking();

    boolean isRecursive();

    /**
     * Defines external profiles that may be activated for the given model.

    default void add(ModelProblem problem) {
        getProblemCollector().reportProblem(problem);
    }

    ModelBuilderException newModelBuilderException();

    void setSource(String location);

    void setSource(Model model);

    String getSource();

    void setRootModel(Model model);

    Model getRootModel();

    super(message);
    this.conflicts = conflicts;
    this.source = source;
  }

  public Set<Feature<?>> getConflicts() {
    return conflicts;
  }

  public Object getSource() {
    return source;
  }

  @Override
  public String getMessage() {
    return super.getMessage() + " (source: " + source + ")";
  }

	} else {
		message = fmt.Sprint(args...)
	}
	logJSON, err := json.Marshal(&log.Entry{
		Level:   FatalKind,
		Message: message,
		Time:    time.Now().UTC(),
		Trace:   &log.Trace{Message: message, Source: []string{getSource(6)}},
	})
	if err != nil {
		panic(err)
	}
	fmt.Fprintln(Output, string(logJSON))
	ExitFunc(1)
}

func (f fatalMsg) quiet(msg string, args ...any) {
	f.pretty(msg, args...)
}

   * Returns the object that originated this event (not the object that originated the
   * wrapped event). This is generally an {@link EventBus}.
   *
   * @return the source of this event.
   */
  public Object getSource() {
    return source;
  }

  /**
   * Returns the wrapped, 'dead' event, which the system was unable to deliver to any registered
   * subscriber.
   *
   * @return the 'dead' event that could not be delivered.