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 rc...@apache.org on 2020/07/28 03:20:52 UTC
[james-project] 24/25: JAMES-3310 Make DeletedMessageVaultHook
failure sensitive
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit d27ac6a60881633033006026cbd328653260746b
Author: Gautier DI FOLCO <gd...@linagora.com>
AuthorDate: Thu Jul 16 16:15:49 2020 +0200
JAMES-3310 Make DeletedMessageVaultHook failure sensitive
---
.../src/main/java/org/apache/james/vault/DeletedMessageVaultHook.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/DeletedMessageVaultHook.java b/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/DeletedMessageVaultHook.java
index 99858f1..72cc971 100644
--- a/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/DeletedMessageVaultHook.java
+++ b/mailbox/plugin/deleted-messages-vault/src/main/java/org/apache/james/vault/DeletedMessageVaultHook.java
@@ -135,6 +135,7 @@ public class DeletedMessageVaultHook implements PreDeletionHook {
return mapperFactory.getMessageIdMapper(session)
.findReactive(ImmutableList.of(deletedMessageMailboxContext.getMessageId()), MessageMapper.FetchType.Full)
.next()
+ .switchIfEmpty(Mono.error(new RuntimeException("Cannot find " + deletedMessageMailboxContext.getMessageId())))
.map(Throwing.function(mailboxMessage -> Pair.of(mailboxMessage,
deletedMessageConverter.convert(deletedMessageMailboxContext, mailboxMessage,
ZonedDateTime.ofInstant(clock.instant(), ZoneOffset.UTC)))))
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org