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