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 3d39f3c JAMES-2294 s/STATE_TRANSPORT/TRANSPORT_PROCESSOR new 98f9ed4 JAMES-2794 RabbitMQ should not dequeue deleted elements new a54fe44 JAMES-2794 Solve an IntelliJ warning new 49939ce JAMES-2794 Demonstrate reprocessing was broken on top of RabbitMQ mailQueue new 3e6f9f3 JAMES-2794 Create an EnqueueId POJO in RabbitMQMailQueue new b29d2e6 JAMES-2794 MailQueue should deliver multiple time the same mail new 961ef33 JAMES-2794 RabbitMQ MailQueue projections should rely on EnqueueId new 7f9a7cb JAMES-2794 Refactor DeleteCondition to implement WithEnqueueId new e4d5c50 JAMES-2794 Reprocessing works on top of the distributed RabbitMQ JAMES new a0c2fe2 JAMES-2794 Upgrade instructions new aad4442 JAMES-2794 Dequeuer should rely on concatMap and not flatMap new 9e9e935 JAMES-2794 Avoid calling *block* in doOnNext new 9d6feef JAMES-2794 Avoid relying on a DTO in RabbitMQ MailQueue logic new 4deed8b JAMES-2794 s/EnQueueId/EnqueueId new 4627075 JAMES-2794 Create an EnqueueId POJO in RabbitMQMailQueue new 92f9e65 JAMES-2794 Solve some "channel closed" exceptions on topof RabbitMQ MailQueue new 1785ab5 JAMES-2794 Avoid relying on a DTO in RabbitMQ MailQueue logic new eeaa8fe JAMES-2794 RabbitMQ should not dequeue deleted elements new 16617ab JAMES-2794 Replace a pair by MailWithEnqueueId new edd3280 JAMES-2794 ack should update the view using an EnqueueId reference new e329898 JAMES-2803 allow configuration of ES request timeout new a7b2cf7 JAMES-2803 ElasticSearch cluster name is no longer useful when using REST API new be0233b JAMES-2803 Always close ES connections new a867be6 JAMES-2803 Finally shorten ReindexingWithEventDeadLettersTest by configuring request timeout new 2be4ed2 JAMES-2659 dispatch result should always be waited for success new 6e53870 JAMES-2659 don't expect too much from eventBus stop new 45d2f06 JAMES-2774 Remove useless comment & rename a test in RabbitMQEventBusTest new 6884456 JAMES-2774 Remove an useless counter field in EventDispatcher new 581b64b JAMES-2774 log when fail to dispatch in EventDispatcher The 28 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: .../apache/james/backends/es/ClientProvider.java | 68 +++++++- .../james/backends/es/ClientProviderImpl.java | 80 --------- .../backends/es/ElasticSearchConfiguration.java | 42 ++--- .../es/ClientProviderImplConnectionTest.java | 30 ++-- .../james/backends/es/ClientProviderImplTest.java | 142 ---------------- ...{AliasNameTest.java => ClientProviderTest.java} | 13 +- .../james/backends/es/DockerElasticSearch.java | 11 +- .../james/backends/es/DockerElasticSearchRule.java | 2 +- .../es/ElasticSearchConfigurationTest.java | 46 ------ .../backends/es/ElasticSearchIndexerTest.java | 90 +++++----- .../backends/es/IndexCreationFactoryTest.java | 17 +- .../james/backends/es/NodeMappingFactoryTest.java | 23 ++- .../backends/es/search/ScrolledSearchTest.java | 181 ++++++++++----------- .../ElasticSearchIntegrationTest.java | 13 +- .../james/mailbox/events/EventDispatcher.java | 4 +- .../james/mailbox/events/RabbitMQEventBusTest.java | 25 ++- ...lasticSearchQuotaSearchTestSystemExtension.java | 13 +- .../ElasticSearchQuotaMailboxListenerTest.java | 6 + .../host/ElasticSearchHostSystem.java | 7 +- .../modules/mailbox/ElasticSearchClientModule.java | 40 +---- .../apache/james/DockerElasticSearchExtension.java | 11 ++ .../modules/TestDockerElasticSearchModule.java | 16 +- .../james/RabbitMQJamesServerReprocessingTest.java | 93 +++++++++++ .../ReindexingWithEventDeadLettersTest.java | 2 +- .../routes/ElasticSearchQuotaSearchExtension.java | 9 +- .../queue/activemq/ActiveMQMailQueueBlobTest.java | 7 + .../queue/activemq/ActiveMQMailQueueTest.java | 7 + .../apache/james/queue/api/MailQueueContract.java | 25 +++ .../queue/api/ManageableMailQueueContract.java | 9 +- .../apache/james/queue/jms/JMSMailQueueTest.java | 7 + .../org/apache/james/queue/rabbitmq/Dequeuer.java | 45 +++-- .../org/apache/james/queue/rabbitmq/EnqueueId.java | 49 +++--- .../apache/james/queue/rabbitmq/EnqueuedItem.java | 37 +++-- .../org/apache/james/queue/rabbitmq/Enqueuer.java | 18 +- .../apache/james/queue/rabbitmq/MailLoader.java | 15 +- .../james/queue/rabbitmq/MailReference.java} | 33 ++-- .../james/queue/rabbitmq/MailReferenceDTO.java | 41 +++-- .../james/queue/rabbitmq/MailWithEnqueueId.java} | 25 +-- .../queue/rabbitmq/RabbitMQMailQueueFactory.java | 3 +- .../queue/rabbitmq/view/api/DeleteCondition.java | 59 +++++-- .../queue/rabbitmq/view/api/MailQueueView.java | 4 +- .../view/cassandra/CassandraMailQueueBrowser.java | 3 +- .../cassandra/CassandraMailQueueMailDelete.java | 19 +-- .../view/cassandra/CassandraMailQueueView.java | 21 ++- .../cassandra/CassandraMailQueueViewModule.java | 15 +- .../rabbitmq/view/cassandra/DeletedMailsDAO.java | 21 +-- .../rabbitmq/view/cassandra/EnqueuedMailsDAO.java | 9 +- .../view/cassandra/EnqueuedMailsDaoUtil.java | 8 +- .../rabbitmq/view/cassandra/model/MailKey.java | 65 -------- .../james/queue/rabbitmq/EnqueuedItemTest.java | 17 ++ .../apache/james/queue/rabbitmq/MailDTOTest.java | 23 ++- .../queue/rabbitmq/RabbitMQMailQueueTest.java | 8 - .../rabbitmq/view/api/DeleteConditionTest.java | 111 ++++++++++--- .../view/cassandra/DeletedMailsDAOTest.java | 35 ++-- .../view/cassandra/EnqueuedMailsDaoTest.java | 17 +- .../view/cassandra/model/EnqueueIdTest.java} | 37 +++-- .../model/EnqueuedItemWithSlicingContextTest.java | 5 +- .../rabbitmq/view/cassandra/model/MailKeyTest.java | 33 ---- .../src/test/resources/json/mail1.json | 1 + .../src/test/resources/json/mail_min.json | 1 + upgrade-instructions.md | 35 ++++ 61 files changed, 957 insertions(+), 895 deletions(-) delete mode 100644 backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/ClientProviderImpl.java delete mode 100644 backends-common/elasticsearch/src/test/java/org/apache/james/backends/es/ClientProviderImplTest.java copy backends-common/elasticsearch/src/test/java/org/apache/james/backends/es/{AliasNameTest.java => ClientProviderTest.java} (81%) create mode 100644 server/container/guice/cassandra-rabbitmq-guice/src/test/java/org/apache/james/RabbitMQJamesServerReprocessingTest.java copy mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events/EventBusId.java => server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/EnqueueId.java (65%) copy server/queue/{queue-api/src/main/java/org/apache/james/queue/api/RawMailQueueItem.java => queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/MailReference.java} (68%) copy server/{mailet/integration-testing/src/test/java/org/apache/james/transport/mailets/ErrorMatcher.java => queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/MailWithEnqueueId.java} (76%) delete mode 100644 server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/model/MailKey.java copy server/{container/util/src/test/java/org/apache/james/util/streams/OffsetTest.java => queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/view/cassandra/model/EnqueueIdTest.java} (62%) delete mode 100644 server/queue/queue-rabbitmq/src/test/java/org/apache/james/queue/rabbitmq/view/cassandra/model/MailKeyTest.java --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org