This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch 3.7.x in repository https://gitbox.apache.org/repos/asf/james-project.git
commit a0e5fdcbf538262e981b1c375e1839668f732ab7 Author: Benoit Tellier <btell...@linagora.com> AuthorDate: Fri Nov 18 12:05:39 2022 +0700 JAMES-3859 configurable -> startable --- .../org/apache/james/utils/InitializationOperations.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/server/container/guice/common/src/main/java/org/apache/james/utils/InitializationOperations.java b/server/container/guice/common/src/main/java/org/apache/james/utils/InitializationOperations.java index fde491545f..f2388d13cd 100644 --- a/server/container/guice/common/src/main/java/org/apache/james/utils/InitializationOperations.java +++ b/server/container/guice/common/src/main/java/org/apache/james/utils/InitializationOperations.java @@ -31,31 +31,31 @@ import com.google.inject.Inject; public class InitializationOperations { private final Set<InitializationOperation> initializationOperations; - private final Startables configurables; + private final Startables startables; @Inject - public InitializationOperations(Set<InitializationOperation> initializationOperations, Startables configurables) { + public InitializationOperations(Set<InitializationOperation> initializationOperations, Startables startables) { this.initializationOperations = initializationOperations; - this.configurables = configurables; + this.startables = startables; } public void initModules() { - Set<InitializationOperation> processed = processConfigurables(); + Set<InitializationOperation> processed = processStartables(); processOthers(processed); } - private Set<InitializationOperation> processConfigurables() { - return configurables.get().stream() + private Set<InitializationOperation> processStartables() { + return startables.get().stream() .flatMap(this::configurationPerformerFor) .distinct() .peek(Throwing.consumer(InitializationOperation::initModule).sneakyThrow()) .collect(Collectors.toSet()); } - private Stream<InitializationOperation> configurationPerformerFor(Class<? extends Startable> configurable) { + private Stream<InitializationOperation> configurationPerformerFor(Class<? extends Startable> startable) { return initializationOperations.stream() - .filter(x -> x.forClass().equals(configurable)); + .filter(x -> x.forClass().equals(startable)); } private void processOthers(Set<InitializationOperation> processed) { --------------------------------------------------------------------- To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org For additional commands, e-mail: notifications-h...@james.apache.org