New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
JAMES-3784 Ease mail repository / event dead letter operation #1062
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What prevents today to have CRON on reprocessing/redelivery is that it is unbounded.
If I have 1 billion entries in there it gonna take a lot of resources to process that.
A rate limit do not really address the concern: that still remains unbounded and we now have a task that takes forever that prevents execution of other task, and the CRON would just add more task in there.
IMO a good old limit is more appropriate/
...common/src/main/java/org/apache/james/modules/ErrorMailRepositoryEmptyHealthCheckModule.java
Show resolved
Hide resolved
...ry-api/src/main/java/org/apache/james/mailrepository/api/MailRepositoryEmptyHealthCheck.java
Outdated
Show resolved
Hide resolved
...ry-api/src/main/java/org/apache/james/mailrepository/api/MailRepositoryEmptyHealthCheck.java
Outdated
Show resolved
Hide resolved
...ry-api/src/main/java/org/apache/james/mailrepository/api/MailRepositoryEmptyHealthCheck.java
Outdated
Show resolved
Hide resolved
...ry-api/src/main/java/org/apache/james/mailrepository/api/MailRepositoryEmptyHealthCheck.java
Outdated
Show resolved
Hide resolved
...ailbox/src/main/java/org/apache/james/webadmin/service/EventDeadLettersRedeliverService.java
Outdated
Show resolved
Hide resolved
...mailrepository/src/main/java/org/apache/james/webadmin/service/ReprocessingAllMailsTask.java
Outdated
Show resolved
Hide resolved
...dmin-mailrepository/src/main/java/org/apache/james/webadmin/service/ReprocessingService.java
Outdated
Show resolved
Hide resolved
} | ||
|
||
private Mono<Task.Result> reprocessAll(Reprocessor reprocessor, MailRepositoryPath path, Configuration configuration, Consumer<MailKey> keyListener) { | ||
return Flux.fromStream(Throwing.supplier(() -> mailRepositoryStoreService.getRepositories(path))) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Any chances this does blocking reads?
...dmin-mailrepository/src/main/java/org/apache/james/webadmin/service/ReprocessingService.java
Outdated
Show resolved
Hide resolved
...ilbox/src/test/java/org/apache/james/webadmin/service/EventDeadLettersRedeliverTaskTest.java
Show resolved
Hide resolved
...repository/src/test/java/org/apache/james/webadmin/service/ReprocessingAllMailsTaskTest.java
Show resolved
Hide resolved
|
...i/src/main/java/org/apache/james/mailrepository/api/EmptyErrorMailRepositoryHealthCheck.java
Outdated
Show resolved
Hide resolved
65a46ff
to
32683f5
Compare
Squash fixup & Complete TODO |
You can rebase it again (sorry) as I just merged #1049 |
… event task, Reprocessing mail task
…deliver event task, Reprocessing mail task
Jira: https://issues.apache.org/jira/projects/JAMES/issues/JAMES-3784