[james-project] 36/38: JAMES-2813 Extract MappingsSourcesMigrationTask

[btellier]

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 2bdebc9a34159f0d1ce69561c2ba52d2573a5e4a
Author: Gautier DI FOLCO <gdifo...@linagora.com>
AuthorDate: Wed Sep 4 14:32:15 2019 +0200

    JAMES-2813 Extract MappingsSourcesMigrationTask
---
 .../migration/MappingsSourcesMigration.java        | 43 +++++++++++++---------
 1 file changed, 26 insertions(+), 17 deletions(-)

diff --git 
a/server/data/data-cassandra/src/main/java/org/apache/james/rrt/cassandra/migration/MappingsSourcesMigration.java
 
b/server/data/data-cassandra/src/main/java/org/apache/james/rrt/cassandra/migration/MappingsSourcesMigration.java
index 6d4f887..425a6e9 100644
--- 
a/server/data/data-cassandra/src/main/java/org/apache/james/rrt/cassandra/migration/MappingsSourcesMigration.java
+++ 
b/server/data/data-cassandra/src/main/java/org/apache/james/rrt/cassandra/migration/MappingsSourcesMigration.java
@@ -40,6 +40,31 @@ import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Mono;
 
 public class MappingsSourcesMigration implements Migration {
+
+    private static class MappingsSourcesMigrationTask implements Task {
+
+        private final MappingsSourcesMigration migration;
+
+        public MappingsSourcesMigrationTask(MappingsSourcesMigration 
migration) {
+            this.migration = migration;
+        }
+
+        @Override
+        public Result run() throws InterruptedException {
+            return migration.runTask();
+        }
+
+        @Override
+        public TaskType type() {
+            return TYPE;
+        }
+
+        @Override
+        public Optional<TaskExecutionDetails.AdditionalInformation> details() {
+            return Optional.of(migration.createAdditionalInformation());
+        }
+    }
+
     private static final Logger LOGGER = 
LoggerFactory.getLogger(MappingsSourcesMigration.class);
     private static final TaskType TYPE = 
TaskType.of("mappingsSourcesMigration");
 
@@ -102,23 +127,7 @@ public class MappingsSourcesMigration implements Migration 
{
 
     @Override
     public Task asTask() {
-        return new Task() {
-
-            @Override
-            public Result run() throws InterruptedException {
-                return runTask();
-            }
-
-            @Override
-            public TaskType type() {
-                return TYPE;
-            }
-
-            @Override
-            public Optional<TaskExecutionDetails.AdditionalInformation> 
details() {
-                return Optional.of(createAdditionalInformation());
-            }
-        };
+        return new MappingsSourcesMigrationTask(this);
     }
 
     AdditionalInformation createAdditionalInformation() {


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org