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 d1cca6c JAMES-2726 Take care of duplication in MemoryMailRepository
new 39afa48 JAMES-2241 can reindex header fields with dots after
upgrading to ES6
new 6ea145a JAMES-2813 Split TaskManager API from Memory implementation
new 5e0302a JAMES-2813 Other modules should depend on
james-server-task-api
new 189ac40 JAMES-2813 s/james-server-task/james-server-task-memory
new 89daf45 JAMES-2813 Group task related projects into a task directory
new 52f1dd5 JAMES-2813 Add description to tasks maven modules
new ca8d502 JAMES-2813 server/app should rely on MemoryTaskManager
new 6e0ca81 JAMES-2739 fix problem for browse mails from queue
new 703220c JAMES-2855 Generate javadoc for MPT cote upon site phase
new 084dcd3 JAMES-2903 Rework default LOG4J log file for Spring
new d1c7fd8 JAMES-2899 ugrade reactor version
new d86bf08 JAMES-2899 replace elastic schedulers by boundedElastic ones
new 7881aa9 JAMES-2899 replace new elastic schedulers by new
boundedElastic ones
new 4ba2d6c JAMES-2899 Stop leaking receivers in RabbitMQWorkQueue
new c7c3119 JAMES-2899 Stop leaking RabbitMQWorkQueue in
DistributedTaskManagerTest
new 7098dce JAMES-2813 MemoryWorkQueue should rely on reactor primitive
new 870c67d JAMES-2862 Implement Remove address mapping in
AddressMappingRoutes + Tests
new eb1e8cf JAMES-2862 Site documentation
The 18 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:
backends-common/cassandra/pom.xml | 7 +-
.../cassandra/init/CassandraTableManager.java | 2 +-
.../cassandra/utils/CassandraAsyncExecutor.java | 2 +-
.../apache/james/backends/es/ClientProvider.java | 4 +-
.../rabbitmq/RabbitMQConnectionFactory.java | 2 +-
.../rabbitmq/ReactorRabbitMQChannelPool.java | 2 +-
.../james/backends/rabbitmq/SimpleChannelPool.java | 4 +-
.../backends/rabbitmq/SimpleConnectionPool.java | 2 +-
.../run/spring/destination/conf/log4j.properties | 35 ++++----
mailbox/api/pom.xml | 7 +-
.../james/mailbox/backup/DefaultMailboxBackup.java | 2 +-
mailbox/cassandra/pom.xml | 7 +-
.../cassandra/mail/CassandraMessageDAO.java | 2 +-
.../cassandra/mail/CassandraMessageIdMapper.java | 4 +-
.../cassandra/mail/CassandraModSeqProvider.java | 2 +-
.../elasticsearch/json/HeaderCollection.java | 5 +-
.../elasticsearch/json/HeaderCollectionTest.java | 4 +-
.../mailbox/events/delivery/EventDelivery.java | 2 +-
.../mailbox/events/delivery/InVmEventDelivery.java | 4 +-
.../james/mailbox/events/EventDispatcher.java | 2 +-
.../james/mailbox/events/GroupRegistration.java | 2 +-
.../mailbox/events/KeyRegistrationHandler.java | 2 +-
.../james/mailbox/events/WaitDelayGenerator.java | 2 +-
.../mailbox/events/LocalListenerRegistryTest.java | 2 +-
.../vault/blob/BlobStoreDeletedMessageVault.java | 2 +-
.../blob/BlobStoreVaultGarbageCollectionTask.java | 2 +-
.../store/search/SimpleMessageSearchIndexTest.java | 5 ++
.../james/mailbox/store/PreDeletionHooks.java | 2 +-
.../james/mailbox/store/StoreMessageManager.java | 2 +-
.../search/AbstractMessageSearchIndexTest.java | 15 ++++
mpt/core/pom.xml | 2 +-
pom.xml | 22 +++--
server/app/pom.xml | 4 +
server/app/src/main/resources/log4j.properties | 55 +++++++++----
.../main/java/org/apache/james/blob/api/Store.java | 2 +-
.../james/blob/cassandra/CassandraBlobStore.java | 6 +-
.../blob/objectstorage/ObjectStorageBlobsDAO.java | 6 +-
.../objectstorage/StreamCompatibleBlobPutter.java | 6 +-
.../blob/objectstorage/aws/AwsS3ObjectStorage.java | 4 +-
.../objectstorage/ObjectStorageBlobsDAOTest.java | 8 +-
.../modules/mailbox/ResilientClusterProvider.java | 4 +-
server/container/guice/guice-common/pom.xml | 2 +-
.../org/apache/james/StartUpChecksPerformer.java | 2 +-
.../james/modules/server/HostnameModule.java | 2 +-
.../apache/james/GuiceLifecycleHeathCheckTest.java | 2 +-
server/container/mailbox-jmx/pom.xml | 5 ++
.../adapter/mailbox/ReIndexerManagementTest.java | 3 +-
.../META-INF/org/apache/james/spring-server.xml | 2 +-
.../main/java/org/apache/james/util/Runnables.java | 4 +-
.../org/apache/james/util/ReactorUtilsTest.java | 8 +-
.../mailetcontainer/impl/JamesMailSpooler.java | 4 +-
.../mailets/remote/delivery/DeliveryRunnable.java | 2 +-
server/pom.xml | 8 +-
.../webadmin/webadmin-cassandra-data/pom.xml | 5 ++
.../routes/CassandraMappingsRoutesTest.java | 2 +-
.../protocols/webadmin/webadmin-cassandra/pom.xml | 5 ++
.../routes/CassandraMigrationRoutesTest.java | 2 +-
server/protocols/webadmin/webadmin-core/pom.xml | 7 +-
.../james/webadmin/dto/ExecutionDetailsDto.java | 2 +-
.../james/webadmin/routes/TasksRoutesTest.java | 2 +-
.../webadmin/routes/AddressMappingRoutes.java | 28 ++++++-
.../webadmin/routes/AddressMappingRoutesTest.java | 95 ++++++++++++++++++----
.../webadmin-mailbox-deleted-message-vault/pom.xml | 5 ++
.../routes/DeletedMessagesVaultRoutesTest.java | 2 +-
server/protocols/webadmin/webadmin-mailbox/pom.xml | 5 ++
.../routes/EventDeadLettersRoutesTest.java | 2 +-
.../webadmin/routes/ReindexingRoutesTest.java | 2 +-
.../protocols/webadmin/webadmin-mailqueue/pom.xml | 5 +-
.../james/webadmin/routes/MailQueueRoutesTest.java | 2 +-
.../webadmin/routes/MailQueueRoutesUnitTest.java | 2 +-
.../webadmin/webadmin-mailrepository/pom.xml | 5 ++
.../routes/MailRepositoriesRoutesTest.java | 2 +-
.../james/queue/api/DelayedMailQueueContract.java | 6 +-
.../api/DelayedPriorityMailQueueContract.java | 4 +-
.../apache/james/queue/api/MailQueueContract.java | 16 ++--
.../james/queue/api/PriorityMailQueueContract.java | 8 +-
.../james/queue/library/MailQueueManagement.java | 6 +-
.../cassandra/CassandraMailQueueMailDelete.java | 2 +-
server/task/{ => task-api}/pom.xml | 15 +---
.../src/main/java/org/apache/james/task/Task.java | 0
.../main/java/org/apache/james/task/TaskId.java | 0
.../java/org/apache/james/task/TaskManager.java | 0
.../apache/james/task/TaskNotFoundException.java | 0
.../main/java/org/apache/james/task/TaskType.java | 0
.../scala/org/apache/james/task/Hostname.scala} | 22 +++--
.../apache/james/task/TaskExecutionDetails.scala | 4 +-
.../java/org/apache/james/task/CompletedTask.java | 0
.../java/org/apache/james/task/FailedTask.java | 0
.../org/apache/james/task/MemoryReferenceTask.java | 0
.../java/org/apache/james/task/TaskIdTest.java | 0
.../org/apache/james/task/TaskManagerContract.java | 3 +-
.../test/java/org/apache/james/task/TaskTest.java | 0
.../java/org/apache/james/task/TaskTypeTest.java | 0
.../java/org/apache/james/task/ThrowingTask.java | 0
server/{ => task}/task-distributed/pom.xml | 15 +++-
.../distributed/RabbitMQExclusiveConsumer.java | 2 +-
.../distributed/RabbitMQTerminationSubscriber.java | 4 +-
.../distributed/RabbitMQWorkQueue.java | 14 ++--
.../distributed/TasksSerializationModule.java | 0
.../CassandraTaskExecutionDetailsProjection.scala | 0
...assandraTaskExecutionDetailsProjectionDAO.scala | 3 +-
...andraTaskExecutionDetailsProjectionModule.scala | 0
.../distributed/RabbitMQWorkQueueSupplier.scala | 4 +-
.../eventsourcing/distributed/TaskEventDTO.scala | 2 +-
...andraTaskExecutionDetailsProjectionDAOTest.java | 0
...assandraTaskExecutionDetailsProjectionTest.java | 0
.../distributed/DistributedTaskManagerTest.java | 49 +++++++++--
.../RabbitMQTerminationSubscriberTest.java | 2 +-
.../distributed/RabbitMQWorkQueueTest.java | 0
.../distributed/TaskEventsSerializationTest.java | 13 +--
server/{ => task}/task-json/pom.xml | 6 +-
.../JsonTaskAdditionalInformationsSerializer.java | 0
.../james/server/task/json/JsonTaskSerializer.java | 0
.../task/json/dto/AdditionalInformationDTO.java | 0
.../json/dto/AdditionalInformationDTOModule.java | 0
.../apache/james/server/task/json/dto/TaskDTO.java | 0
.../james/server/task/json/dto/TaskDTOModule.java | 0
.../server/task/json/TaskDeserializerTest.java | 0
.../server/task/json/TaskSerializationTest.java | 0
.../james/server/task/json/TaskSerializerTest.java | 0
.../apache/james/server/task/json/TestTask.java | 0
.../server/task/json/dto/CompletedTaskDTO.java | 0
.../james/server/task/json/dto/FailedTaskDTO.java | 0
.../task/json/dto/MemoryReferenceTaskDTO.java | 0
.../task/json/dto/MemoryReferenceTaskStore.java | 0
.../james/server/task/json/dto/TestTaskDTO.java | 0
.../server/task/json/dto/TestTaskDTOModules.java | 0
.../server/task/json/dto/ThrowingTaskDTO.java | 0
server/task/{ => task-memory}/pom.xml | 16 +++-
.../org/apache/james/task/MemoryTaskManager.java | 5 +-
.../org/apache/james/task/MemoryWorkQueue.java | 21 ++---
.../apache/james/task/SerialTaskManagerWorker.java | 0
.../james/task/TaskExecutionDetailsUpdater.java | 0
.../org/apache/james/task/TaskManagerWorker.java | 0
.../java/org/apache/james/task/TaskWithId.java | 0
.../main/java/org/apache/james/task/WorkQueue.java | 0
.../james/task/eventsourcing/CommandHandlers.scala | 2 +-
.../task/eventsourcing/DecisionProjection.scala | 0
.../eventsourcing/EventSourcingTaskManager.scala | 2 +-
.../apache/james/task/eventsourcing/Events.scala | 20 +----
.../eventsourcing/ScalaEventSourcingSystem.scala | 0
.../james/task/eventsourcing/TaskAggregate.scala | 2 +-
.../james/task/eventsourcing/TaskAggregateId.scala | 0
.../james/task/eventsourcing/TaskCommand.scala | 0
.../TaskExecutionDetailsProjection.scala | 5 +-
.../task/eventsourcing/TerminationSubscriber.scala | 0
.../task/eventsourcing/WorkQueueSupplier.scala | 0
.../task/eventsourcing/WorkerStatusListener.scala | 0
.../apache/james/task/CountDownLatchExtension.java | 0
.../apache/james/task/MemoryTaskManagerTest.java | 2 -
.../james/task/SerialTaskManagerWorkerTest.java | 0
.../java/org/apache/james/task/TaskWithIdTest.java | 0
.../EventSourcingTaskManagerTest.java | 3 +-
.../MemoryTaskExecutionDetailsProjectionTest.java | 0
.../MemoryTerminationSubscriberTest.java | 0
.../TaskExecutionDetailsProjectionContract.java | 0
.../TerminationSubscriberContract.java | 11 +--
.../james/task/TaskExecutionDetailsFixture.scala | 1 -
src/site/markdown/server/manage-webadmin.md | 26 +++++-
159 files changed, 520 insertions(+), 276 deletions(-)
copy server/task/{ => task-api}/pom.xml (85%)
rename server/task/{ =>
task-api}/src/main/java/org/apache/james/task/Task.java (100%)
rename server/task/{ =>
task-api}/src/main/java/org/apache/james/task/TaskId.java (100%)
rename server/task/{ =>
task-api}/src/main/java/org/apache/james/task/TaskManager.java (100%)
rename server/task/{ =>
task-api}/src/main/java/org/apache/james/task/TaskNotFoundException.java (100%)
rename server/task/{ =>
task-api}/src/main/java/org/apache/james/task/TaskType.java (100%)
copy
server/task/{src/main/scala/org/apache/james/task/eventsourcing/WorkQueueSupplier.scala
=> task-api/src/main/scala/org/apache/james/task/Hostname.scala} (65%)
rename server/task/{ =>
task-api}/src/main/scala/org/apache/james/task/TaskExecutionDetails.scala (99%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/CompletedTask.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/FailedTask.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/MemoryReferenceTask.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/TaskIdTest.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/TaskManagerContract.java (99%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/TaskTest.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/TaskTypeTest.java (100%)
rename server/task/{ =>
task-api}/src/test/java/org/apache/james/task/ThrowingTask.java (100%)
rename server/{ => task}/task-distributed/pom.xml (93%)
rename server/{ =>
task}/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
(98%)
rename server/{ =>
task}/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java
(98%)
rename server/{ =>
task}/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java
(93%)
rename server/{ =>
task}/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/TasksSerializationModule.java
(100%)
rename server/{ =>
task}/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjection.scala
(100%)
rename server/{ =>
task}/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionDAO.scala
(97%)
rename server/{ =>
task}/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionModule.scala
(100%)
rename server/{ =>
task}/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala
(96%)
rename server/{ =>
task}/task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/TaskEventDTO.scala
(99%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionDAOTest.java
(100%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionTest.java
(100%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
(88%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java
(98%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java
(100%)
rename server/{ =>
task}/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/TaskEventsSerializationTest.java
(99%)
rename server/{ => task}/task-json/pom.xml (90%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/JsonTaskAdditionalInformationsSerializer.java
(100%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/JsonTaskSerializer.java
(100%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/dto/AdditionalInformationDTO.java
(100%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/dto/AdditionalInformationDTOModule.java
(100%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/dto/TaskDTO.java
(100%)
rename server/{ =>
task}/task-json/src/main/java/org/apache/james/server/task/json/dto/TaskDTOModule.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/TaskDeserializerTest.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/TaskSerializationTest.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/TaskSerializerTest.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/TestTask.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/CompletedTaskDTO.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/FailedTaskDTO.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/MemoryReferenceTaskDTO.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/MemoryReferenceTaskStore.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/TestTaskDTO.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/TestTaskDTOModules.java
(100%)
rename server/{ =>
task}/task-json/src/test/java/org/apache/james/server/task/json/dto/ThrowingTaskDTO.java
(100%)
rename server/task/{ => task-memory}/pom.xml (82%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/MemoryTaskManager.java (98%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/MemoryWorkQueue.java (80%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/SerialTaskManagerWorker.java
(100%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/TaskExecutionDetailsUpdater.java
(100%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/TaskManagerWorker.java (100%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/TaskWithId.java (100%)
rename server/task/{ =>
task-memory}/src/main/java/org/apache/james/task/WorkQueue.java (100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/CommandHandlers.scala
(98%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/DecisionProjection.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/EventSourcingTaskManager.scala
(99%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/Events.scala
(80%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/ScalaEventSourcingSystem.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/TaskAggregate.scala
(98%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/TaskAggregateId.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/TaskCommand.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/TaskExecutionDetailsProjection.scala
(96%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/TerminationSubscriber.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/WorkQueueSupplier.scala
(100%)
rename server/task/{ =>
task-memory}/src/main/scala/org/apache/james/task/eventsourcing/WorkerStatusListener.scala
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/CountDownLatchExtension.java
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/MemoryTaskManagerTest.java
(97%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/SerialTaskManagerWorkerTest.java
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/TaskWithIdTest.java (100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/eventsourcing/EventSourcingTaskManagerTest.java
(98%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/eventsourcing/MemoryTaskExecutionDetailsProjectionTest.java
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/eventsourcing/MemoryTerminationSubscriberTest.java
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/eventsourcing/TaskExecutionDetailsProjectionContract.java
(100%)
rename server/task/{ =>
task-memory}/src/test/java/org/apache/james/task/eventsourcing/TerminationSubscriberContract.java
(95%)
rename server/task/{ =>
task-memory}/src/test/scala/org/apache/james/task/TaskExecutionDetailsFixture.scala
(98%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
