This is an automated email from the ASF dual-hosted git repository. btellier pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git.
from 77e4f75 JAMES-3145 document metrics logger new d563e4a [Refactoring] Move MailboxACLJsonConverter from mailbox/store to mailbox/cassandra new 10e1a44 JAMES-3143 Add select all query for MessageId/ImapUid new e31d789 JAMES-3143 SolveMessageInconsistenciesService/Test new 01cb8d1 JAMES-3143 Add context & objects describing inconsistencies new 84374e5 JAMES-3143 SolveMessageInconsistenciesTask/DTO new 4db5a1f JAMES-3143 Guice binding for task new 6ceec97 JAMES-3143 Exposes task in MessageRoutes new c638eff JAMES-3143 Add Webadmin integration test new a7d33f7 JAMES-3143 Update webadmin documentation new e0ce72b JAMES-3143 Update CHANGELOG new ab4e4e3 JAMES-3138 Task for recomputing current quotas new 1b0bc6e JAMES-3138 Webadmin endpoint and guice bindings for recomputing current quotas new 5178d1a JAMES-3138 Changelog entry new 251a73d JAMES-3138 Documentation for Recomputing current quotas endpoint new 7f5a694 JAMES-3138 Task for recomputing current quotas new 6e59725 JAMES-3138 Integration tests for consistency tasks new 1157a7b JAMES-3138 Use concatMap upon quota computation new 00160a4 JAMES-3138 CassandraCurrentQuotaManager: Improve Reactor code style new e73dfb8 JAMES-3138 InMemoryCurrentQuotaManager: Improve reactor code style new fc528ae JAMES-3138 Cassandra test instumentation: inject failure after awaitOn new 9266b93 JAMES-3138 VarArg for Cassandra instrumentation scenari registration new d018a04 JAMES-3138 Add fix nothing integration tests new 12a5987 JAMES-3065 remove remaining usages of Reactor types in public api new e781322 JAMES-3065 s/HealthCheck::checkReactive/HealthCheck::check/ new f5b2483 JAMES-3065 s/HealthCheck::checkReactive/HealthCheck::check/ new 7cb8ba9 JAMES-3153 make use of RetryWhen for backoff on reactor new b4de77a JAMES-3153 use reactor.Retry insteaf of reactor-extra version The 27 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: CHANGELOG.md | 4 +- .../cassandra/init/ResilientClusterProvider.java | 4 +- .../cassandra/utils/CassandraHealthCheck.java | 2 +- .../apache/james/backends/cassandra/Scenario.java | 23 +- .../james/backends/cassandra/TestingSession.java | 6 +- .../backends/cassandra/TestingSessionTest.java | 31 +- .../cassandra/utils/CassandraHealthCheckTest.java | 8 +- .../apache/james/backends/es/ClientProvider.java | 4 +- .../backends/es/ElasticSearchHealthCheck.java | 2 +- .../es/ElasticSearchHealthCheckConnectionTest.java | 4 +- .../rabbitmq/RabbitMQConnectionFactory.java | 4 +- .../backends/rabbitmq/RabbitMQHealthCheck.java | 2 +- .../rabbitmq/ReactorRabbitMQChannelPool.java | 6 +- .../backends/rabbitmq/SimpleConnectionPool.java | 4 +- .../backends/rabbitmq/RabbitMQHealthCheckTest.java | 28 +- core/pom.xml | 4 + .../apache/james/core/healthcheck/HealthCheck.java | 10 +- mailbox/api/pom.xml | 4 + .../events/EventDeadLettersHealthCheck.java | 2 +- .../mailbox/events/RetryBackoffConfiguration.java | 1 - .../org/apache/james/mailbox/model/QuotaRoot.java | 5 + .../EventDeadLettersHealthCheckContract.java | 30 +- .../apache/james/mailbox/model/QuotaRootTest.java | 24 + .../cassandra}/json/MailboxACLJsonConverter.java | 2 +- .../mailbox/cassandra/mail/CassandraACLMapper.java | 2 +- .../cassandra/mail/CassandraMailboxMapper.java | 7 +- .../cassandra/mail/CassandraMessageIdDAO.java | 12 + .../cassandra/mail/CassandraMessageIdMapper.java | 3 +- .../mail/CassandraMessageIdToImapUidDAO.java | 11 + .../cassandra/mail/CassandraMessageMapper.java | 3 +- .../cassandra/mail/CassandraModSeqProvider.java | 4 +- .../cassandra/mail/CassandraUidProvider.java | 4 +- .../mail/task/MessageInconsistenciesEntry.java | 92 ++++ .../task/SolveMessageInconsistenciesService.java | 443 ++++++++++++++++ .../mail/task/SolveMessageInconsistenciesTask.java | 143 ++++++ ...nconsistenciesTaskAdditionalInformationDTO.java | 135 +++++ ...ava => SolveMessageInconsistenciesTaskDTO.java} | 26 +- .../quota/CassandraCurrentQuotaManager.java | 12 +- .../json/MailboxACLJsonConverterTest.java | 2 +- .../cassandra/mail/CassandraACLMapperTest.java | 6 +- .../cassandra/mail/CassandraMailboxDAOTest.java | 2 +- .../SolveMessageInconsistenciesServiceTest.java | 561 +++++++++++++++++++++ ...essageInconsistenciesTaskSerializationTest.java | 78 +++ ...ssageInconsistencies.additionalInformation.json | 28 + .../json/solveMessageInconsistencies.task.json | 3 + .../mailbox/events/delivery/EventDelivery.java | 6 +- .../james/mailbox/events/GroupRegistration.java | 4 +- .../mailbox/events/KeyRegistrationHandler.java | 10 +- .../quota/InMemoryCurrentQuotaManager.java | 12 +- mailbox/tools/quota-recompute/pom.xml | 20 + .../quota/task/RecomputeCurrentQuotasService.java | 2 +- .../quota/task/RecomputeCurrentQuotasTask.java} | 59 ++- ...eCurrentQuotasTaskAdditionalInformationDTO.java | 79 ++- .../quota/task/RecomputeCurrentQuotasTaskDTO.java} | 25 +- ...computeCurrentQuotasTaskSerializationTest.java} | 37 +- metrics/metrics-tests/pom.xml | 4 + pom.xml | 2 +- server/blob/blob-objectstorage/pom.xml | 4 - .../objectstorage/StreamCompatibleBlobPutter.java | 19 +- .../blob/objectstorage/aws/AwsS3ObjectStorage.java | 11 +- .../org/apache/james/CassandraJamesServerMain.java | 2 + .../webadmin/InconsistencySolvingRoutesModule.java | 16 + .../guice/cassandra-rabbitmq-guice/pom.xml | 4 + .../james/modules/TaskSerializationModule.java | 26 + .../apache/james/GuiceLifecycleHealthCheck.java | 2 +- .../org/apache/james/PeriodicalHealthChecks.java | 2 +- .../apache/james/PeriodicalHealthChecksTest.java | 16 +- .../java/org/apache/james/JPAJamesServerMain.java | 2 + .../org/apache/james/modules/MailboxProbeImpl.java | 6 + ...=> InconsistencyQuotasSolvingRoutesModule.java} | 18 +- .../james/modules/server/MailboxRoutesModule.java | 2 + .../james/modules/server/MessagesRoutesModule.java | 5 + server/data/data-jmap/pom.xml | 4 + .../MessageFastViewProjectionHealthCheck.java | 20 +- .../MessageFastViewProjectionHealthCheckTest.java | 26 +- .../james/jpa/healthcheck/JPAHealthCheck.java | 24 +- .../james/jpa/healthcheck/JPAHealthCheckTest.java | 4 +- .../transport/mailets/delivery/MailDispatcher.java | 3 +- .../rabbitmq/ConsistencyTasksIntegrationTest.java | 446 ++++++++++++++++ .../RabbitMQWebAdminServerIntegrationTest.java | 33 ++ ...dminServerTaskSerializationIntegrationTest.java | 22 +- ... SolveMessageInconsistenciesRequestToTask.java} | 13 +- .../james/webadmin/routes/HealthCheckRoutes.java | 17 +- .../org/apache/james/webadmin/WebAdminUtils.java | 3 +- .../webadmin/routes/HealthCheckRoutesTest.java | 6 +- server/protocols/webadmin/webadmin-mailbox/pom.xml | 4 + .../james/webadmin/routes/MessagesRoutes.java | 38 +- .../RecomputeCurrentQuotasRequestToTask.java} | 12 +- .../james/webadmin/routes/UserQuotaRoutes.java | 59 ++- .../james/webadmin/routes/MessageRoutesTest.java | 4 +- .../routes/WebAdminQuotaSearchTestSystem.java | 11 +- server/queue/queue-activemq/pom.xml | 2 +- .../distributed/RabbitMQWorkQueue.java | 8 +- src/site/markdown/server/manage-webadmin.md | 105 +++- 94 files changed, 2710 insertions(+), 340 deletions(-) rename mailbox/{store/src/main/java/org/apache/james/mailbox/store => cassandra/src/main/java/org/apache/james/mailbox/cassandra}/json/MailboxACLJsonConverter.java (98%) create mode 100644 mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/MessageInconsistenciesEntry.java create mode 100644 mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/SolveMessageInconsistenciesService.java create mode 100644 mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/SolveMessageInconsistenciesTask.java create mode 100644 mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/SolveMessageInconsistenciesTaskAdditionalInformationDTO.java copy mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/{SolveMailboxInconsistenciesTaskDTO.java => SolveMessageInconsistenciesTaskDTO.java} (64%) rename mailbox/{store/src/test/java/org/apache/james/mailbox/store => cassandra/src/test/java/org/apache/james/mailbox/cassandra}/json/MailboxACLJsonConverterTest.java (99%) create mode 100644 mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/task/SolveMessageInconsistenciesServiceTest.java create mode 100644 mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/task/SolveMessageInconsistenciesTaskSerializationTest.java create mode 100644 mailbox/cassandra/src/test/resources/json/solveMessageInconsistencies.additionalInformation.json create mode 100644 mailbox/cassandra/src/test/resources/json/solveMessageInconsistencies.task.json copy mailbox/{cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/RecomputeMailboxCountersTask.java => tools/quota-recompute/src/main/java/org/apache/james/mailbox/quota/task/RecomputeCurrentQuotasTask.java} (58%) copy server/protocols/webadmin/webadmin-jmap/src/main/java/org/apache/james/webadmin/data/jmap/RecomputeUserFastViewTaskAdditionalInformationDTO.java => mailbox/tools/quota-recompute/src/main/java/org/apache/james/mailbox/quota/task/RecomputeCurrentQuotasTaskAdditionalInformationDTO.java (51%) copy mailbox/{cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/task/RecomputeMailboxCountersTaskDTO.java => tools/quota-recompute/src/main/java/org/apache/james/mailbox/quota/task/RecomputeCurrentQuotasTaskDTO.java} (63%) copy mailbox/{cassandra/src/test/java/org/apache/james/mailbox/cassandra/mail/task/RecomputeMailboxCountersTaskSerializationTest.java => tools/quota-recompute/src/test/java/org/apache/james/mailbox/quota/task/RecomputeCurrentQuotasTaskSerializationTest.java} (55%) copy server/container/guice/protocols/webadmin-mailbox/src/main/java/org/apache/james/modules/server/{MailboxesExportRoutesModule.java => InconsistencyQuotasSolvingRoutesModule.java} (73%) create mode 100644 server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/ConsistencyTasksIntegrationTest.java copy server/protocols/webadmin/webadmin-cassandra/src/main/java/org/apache/james/webadmin/routes/{RecomputeMailboxCountersRequestToTask.java => SolveMessageInconsistenciesRequestToTask.java} (74%) copy server/protocols/webadmin/{webadmin-cassandra/src/main/java/org/apache/james/webadmin/routes/RecomputeMailboxCountersRequestToTask.java => webadmin-mailbox/src/main/java/org/apache/james/webadmin/routes/RecomputeCurrentQuotasRequestToTask.java} (75%) --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org