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