@Test void shouldStoreEventInDeadLettersWhenComputeFastViewPrecomputedPropertiesException() throws Exception { doThrow(new IOException()) .when(listener) .computeFastViewPrecomputedProperties(any()); inboxMessageManager.appendMessage( MessageManager.AppendCommand.builder() .build(previewMessage()), mailboxSession); assertThat(eventDeadLetters.failedIds(ComputeMessageFastViewProjectionListener.GROUP).collectList().block()) .hasSize(1); }
@VisibleForTesting MessageFastViewPrecomputedProperties computeFastViewPrecomputedProperties(MessageResult messageResult) throws MailboxException, IOException { return messageFastViewPrecomputedPropertiesFactory.from(messageResult); }
ComputeMessageFastViewProjectionListener implements MailboxListener.ReactiveGroupMailboxListener { @VisibleForTesting MessageFastViewPrecomputedProperties computeFastViewPrecomputedProperties(MessageResult messageResult) throws MailboxException, IOException { return messageFastViewPrecomputedPropertiesFactory.from(messageResult); } }
ComputeMessageFastViewProjectionListener implements MailboxListener.ReactiveGroupMailboxListener { @VisibleForTesting MessageFastViewPrecomputedProperties computeFastViewPrecomputedProperties(MessageResult messageResult) throws MailboxException, IOException { return messageFastViewPrecomputedPropertiesFactory.from(messageResult); } @Inject  ComputeMessageFastViewProjectionListener(SessionProvider sessionProvider, MessageIdManager messageIdManager,
                                                    MessageFastViewProjection messageFastViewProjection,
                                                    MessageFastViewPrecomputedProperties.Factory messageFastViewPrecomputedPropertiesFactory); }
ComputeMessageFastViewProjectionListener implements MailboxListener.ReactiveGroupMailboxListener { @VisibleForTesting MessageFastViewPrecomputedProperties computeFastViewPrecomputedProperties(MessageResult messageResult) throws MailboxException, IOException { return messageFastViewPrecomputedPropertiesFactory.from(messageResult); } @Inject  ComputeMessageFastViewProjectionListener(SessionProvider sessionProvider, MessageIdManager messageIdManager,
                                                    MessageFastViewProjection messageFastViewProjection,
                                                    MessageFastViewPrecomputedProperties.Factory messageFastViewPrecomputedPropertiesFactory); @Override Group getDefaultGroup(); @Override Mono<Void> reactiveEvent(Event event); }
ComputeMessageFastViewProjectionListener implements MailboxListener.ReactiveGroupMailboxListener { @VisibleForTesting MessageFastViewPrecomputedProperties computeFastViewPrecomputedProperties(MessageResult messageResult) throws MailboxException, IOException { return messageFastViewPrecomputedPropertiesFactory.from(messageResult); } @Inject  ComputeMessageFastViewProjectionListener(SessionProvider sessionProvider, MessageIdManager messageIdManager,
                                                    MessageFastViewProjection messageFastViewProjection,
                                                    MessageFastViewPrecomputedProperties.Factory messageFastViewPrecomputedPropertiesFactory); @Override Group getDefaultGroup(); @Override Mono<Void> reactiveEvent(Event event);  }