You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2022/12/07 04:40:38 UTC
[james-project] 02/03: JAMES-3859 configurable -> startable
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 <bt...@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-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org