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