You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/05/30 07:22:17 UTC
[james-project] 06/19: MAILBOX-351 Interface for task information
providing failures details
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 2fd5f4c871114eab30f46834a56801e14f357389
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Thu May 23 11:49:17 2019 +0700
MAILBOX-351 Interface for task information providing failures details
---
.../mailbox/tools/indexer/FullReindexingTask.java | 5 +++-
.../tools/indexer/IndexingDetailInformation.java | 28 ++++++++++++++++++++++
.../indexer/PreviousFailuresReIndexationTask.java | 2 +-
.../tools/indexer/SingleMailboxReindexingTask.java | 5 +++-
.../mailbox/tools/indexer/UserReindexingTask.java | 9 ++++++-
5 files changed, 45 insertions(+), 4 deletions(-)
diff --git a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/FullReindexingTask.java b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/FullReindexingTask.java
index a9ebec8..848f8c7 100644
--- a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/FullReindexingTask.java
+++ b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/FullReindexingTask.java
@@ -31,21 +31,24 @@ public class FullReindexingTask implements Task {
public static final String FULL_RE_INDEXING = "FullReIndexing";
- public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation {
+ public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation, IndexingDetailInformation {
private final ReprocessingContext reprocessingContext;
AdditionalInformation(ReprocessingContext reprocessingContext) {
this.reprocessingContext = reprocessingContext;
}
+ @Override
public int getSuccessfullyReprocessMailCount() {
return reprocessingContext.successfullyReprocessedMailCount();
}
+ @Override
public int getFailedReprocessedMailCount() {
return reprocessingContext.failedReprocessingMailCount();
}
+ @Override
public ReIndexingExecutionFailures failures() {
return reprocessingContext.failures();
}
diff --git a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/IndexingDetailInformation.java b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/IndexingDetailInformation.java
new file mode 100644
index 0000000..063092a
--- /dev/null
+++ b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/IndexingDetailInformation.java
@@ -0,0 +1,28 @@
+/****************************************************************
+ * Licensed to the Apache Software Foundation (ASF) under one *
+ * or more contributor license agreements. See the NOTICE file *
+ * distributed with this work for additional information *
+ * regarding copyright ownership. The ASF licenses this file *
+ * to you under the Apache License, Version 2.0 (the *
+ * "License"); you may not use this file except in compliance *
+ * with the License. You may obtain a copy of the License at *
+ * *
+ * http://www.apache.org/licenses/LICENSE-2.0 *
+ * *
+ * Unless required by applicable law or agreed to in writing, *
+ * software distributed under the License is distributed on an *
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY *
+ * KIND, either express or implied. See the License for the *
+ * specific language governing permissions and limitations *
+ * under the License. *
+ ****************************************************************/
+
+package org.apache.mailbox.tools.indexer;
+
+public interface IndexingDetailInformation {
+ int getSuccessfullyReprocessMailCount();
+
+ int getFailedReprocessedMailCount();
+
+ ReIndexingExecutionFailures failures();
+}
diff --git a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/PreviousFailuresReIndexationTask.java b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/PreviousFailuresReIndexationTask.java
index ceed5cd..a64b2d7 100644
--- a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/PreviousFailuresReIndexationTask.java
+++ b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/PreviousFailuresReIndexationTask.java
@@ -27,7 +27,7 @@ import org.apache.james.task.TaskExecutionDetails;
public class PreviousFailuresReIndexationTask implements Task {
public static final String PREVIOUS_FAILURES_INDEXING = "ReIndexPreviousFailures";
- public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation {
+ public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation, IndexingDetailInformation {
private final ReprocessingContext reprocessingContext;
AdditionalInformation(ReprocessingContext reprocessingContext) {
diff --git a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/SingleMailboxReindexingTask.java b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/SingleMailboxReindexingTask.java
index 138f8a4..9a66481 100644
--- a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/SingleMailboxReindexingTask.java
+++ b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/SingleMailboxReindexingTask.java
@@ -31,7 +31,7 @@ public class SingleMailboxReindexingTask implements Task {
public static final String MAILBOX_RE_INDEXING = "mailboxReIndexing";
- public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation {
+ public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation, IndexingDetailInformation {
private final MailboxId mailboxId;
private final ReprocessingContext reprocessingContext;
@@ -45,14 +45,17 @@ public class SingleMailboxReindexingTask implements Task {
return mailboxId.serialize();
}
+ @Override
public int getSuccessfullyReprocessMailCount() {
return reprocessingContext.successfullyReprocessedMailCount();
}
+ @Override
public int getFailedReprocessedMailCount() {
return reprocessingContext.failedReprocessingMailCount();
}
+ @Override
public ReIndexingExecutionFailures failures() {
return reprocessingContext.failures();
}
diff --git a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/UserReindexingTask.java b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/UserReindexingTask.java
index dab53e7..4088db2 100644
--- a/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/UserReindexingTask.java
+++ b/mailbox/tools/indexer/src/main/java/org/apache/mailbox/tools/indexer/UserReindexingTask.java
@@ -32,7 +32,7 @@ public class UserReindexingTask implements Task {
public static final String USER_RE_INDEXING = "userReIndexing";
- public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation {
+ public static class AdditionalInformation implements TaskExecutionDetails.AdditionalInformation, IndexingDetailInformation {
private final ReprocessingContext reprocessingContext;
private final User user;
@@ -41,14 +41,21 @@ public class UserReindexingTask implements Task {
this.user = user;
}
+ @Override
public int getSuccessfullyReprocessMailCount() {
return reprocessingContext.successfullyReprocessedMailCount();
}
+ @Override
public int getFailedReprocessedMailCount() {
return reprocessingContext.failedReprocessingMailCount();
}
+ @Override
+ public ReIndexingExecutionFailures failures() {
+ return reprocessingContext.failures();
+ }
+
public String getUser() {
return user.asString();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org