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/11/22 05:48:42 UTC
[james-project] 01/04: JAMES-3859 configurable -> startable
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 4e5ef9ec36c1bc3f53d9605e2a16d71cc7717de4
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