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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
