This is an automated email from the ASF dual-hosted git repository.
rouazana pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git.
from fe0af0b JAMES-2813 Add Architecture Decision Record about Distributed
Task Manager
new b483682 JAMES-2813 handle UpdateAdditionalInformation command into
the aggregate
new ad2c55c JAMES-2813 refactor TaskAggregate to prevent creation of the
aggregate if History doesn't start with Created event
new d74ecf0 JAMES-2813 refactor TaskAggregate to split infrastructure
code from logic
new 5da39ae JAMES-2813 replace mocks in RabbitMQWorkQueueTest by a stub
new 604c27d JAMES-2813 rename fields and methods in RabbitMQWorkQueueTest
new c58f80a JAMES-2813 handle additional information in projection
new e1e3e5d JAMES-2813 worker now calls Listener.updated once per second
new 12559bd JAMES-2813 put executeWithSemaphore building blocks into
submethods
new 1b1ee83 JAMES-2813 wire UpdateAdditionalInformation command in the
Event Sourcing system
new 0f0b834 JAMES-2813 prevent cassandra cleanup to happen before
countdown latch release
new e99bc34 JAMES-2813 run AdditionalInformation polling into an elastic
scheduler
new 769d64e JAMES-2813 check that AdditionalInformation instances are
shared between nodes
new e1ff8c5 JAMES-2813 change polling intervall and make it a parameter
of the worker
new 139e70c JAMES-2813 add a timestamp on every AdditionalInformation
new eb5f1be JAMES-2813 delete rabbitmq queue after each test on
distributed task manager
new 1da890c JAMES-2813 use timestamp in additional information to refuse
stalled update event
new a21e5ec JAMES-2813 use immutable datastructure when building history
in TaskAggregateTest
The 17 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:
.../cassandra/migration/MigrationTask.java | 13 +-
.../MigrationTaskAdditionalInformationsDTO.java | 16 +-
.../migration/MigrationTaskSerializationTest.java | 8 +-
.../james/backends/rabbitmq/RabbitMQExtension.java | 4 +-
.../apache/james/json/JsonGenericSerializer.java | 2 +
.../mail/migration/MailboxPathV2Migration.java | 13 +-
...athV2MigrationTaskAdditionalInformationDTO.java | 18 ++-
.../cassandra/mail/task/MailboxMergingTask.java | 14 +-
...MailboxMergingTaskAdditionalInformationDTO.java | 18 ++-
...ailboxPathV2MigrationTaskSerializationTest.java | 6 +-
.../mail/task/MailboxMergingTaskTest.java | 6 +-
.../blob/BlobStoreVaultGarbageCollectionTask.java | 13 +-
...bageCollectionTaskAdditionalInformationDTO.java | 17 ++-
...aultGarbageCollectionTaskSerializationTest.java | 6 +-
.../tools/indexer/MessageIdReIndexingTask.java | 13 +-
...geIdReindexingTaskAdditionalInformationDTO.java | 22 ++-
.../indexer/ReprocessingContextInformation.java | 25 +++-
.../indexer/ReprocessingContextInformationDTO.java | 40 +++--
.../tools/indexer/SingleMailboxReindexingTask.java | 9 +-
...lboxReindexingTaskAdditionalInformationDTO.java | 23 ++-
.../tools/indexer/SingleMessageReindexingTask.java | 13 +-
...sageReindexingTaskAdditionalInformationDTO.java | 25 +++-
.../mailbox/tools/indexer/UserReindexingTask.java | 9 +-
...UserReindexingTaskAdditionalInformationDTO.java | 22 ++-
...rorRecoveryIndexationTaskSerializationTest.java | 8 +-
.../FullReindexingTaskSerializationTest.java | 9 +-
.../MessageIdReindexingTaskSerializationTest.java | 9 +-
...ngleMailboxReindexingTaskSerializationTest.java | 9 +-
...ngleMessageReindexingTaskSerializationTest.java | 9 +-
.../UserReindexingTaskSerializationTest.java | 9 +-
.../james/modules/TaskSerializationModule.java | 4 +-
.../migration/MappingsSourcesMigration.java | 14 +-
...urcesMigrationTaskAdditionalInformationDTO.java | 25 +++-
...pingsSourcesMigrationTaskSerializationTest.java | 6 +-
.../routes/DeletedMessagesVaultDeleteTask.java | 13 +-
...gesVaultDeleteTaskAdditionalInformationDTO.java | 16 +-
.../routes/DeletedMessagesVaultExportTask.java | 14 +-
...gesVaultExportTaskAdditionalInformationDTO.java | 18 ++-
.../routes/DeletedMessagesVaultRestoreTask.java | 13 +-
...esVaultRestoreTaskAdditionalInformationDTO.java | 18 ++-
...edMessagesVaultDeleteTaskSerializationTest.java | 9 +-
...edMessagesVaultExportTaskSerializationTest.java | 7 +-
...dMessagesVaultRestoreTaskSerializationTest.java | 7 +-
.../service/EventDeadLettersRedeliverAllTask.java | 4 +-
.../EventDeadLettersRedeliverGroupTask.java | 4 +-
.../service/EventDeadLettersRedeliverOneTask.java | 7 +-
...LettersRedeliveryTaskAdditionalInformation.java | 15 +-
...tersRedeliveryTaskAdditionalInformationDTO.java | 40 +++--
.../service/EventDeadLettersRedeliverTaskTest.java | 14 +-
.../james/webadmin/service/ClearMailQueueTask.java | 13 +-
...ClearMailQueueTaskAdditionalInformationDTO.java | 18 ++-
.../service/DeleteMailsFromMailQueueTask.java | 13 +-
...sFromMailQueueTaskAdditionalInformationDTO.java | 17 ++-
.../webadmin/service/ClearMailQueueTaskTest.java | 8 +-
.../service/DeleteMailsFromMailQueueTaskTest.java | 12 +-
.../webadmin/routes/MailRepositoriesRoutes.java | 3 +-
.../webadmin/service/ClearMailRepositoryTask.java | 13 +-
...MailRepositoryTaskAdditionalInformationDTO.java | 17 ++-
.../webadmin/service/ReprocessingAllMailsTask.java | 13 +-
...essingAllMailsTaskAdditionalInformationDTO.java | 16 +-
.../webadmin/service/ReprocessingOneMailTask.java | 19 ++-
...cessingOneMailTaskAdditionalInformationDTO.java | 16 +-
.../service/ReprocessingOneMailTaskDTO.java | 10 +-
.../service/ClearMailRepositoryTaskTest.java | 10 +-
.../service/ReprocessingAllMailsTaskTest.java | 11 +-
.../service/ReprocessingOneMailTaskTest.java | 22 ++-
.../apache/james/task/TaskExecutionDetails.scala | 25 +++-
.../james/task/MemoryReferenceWithCounterTask.java | 27 +++-
.../org/apache/james/task/TaskManagerContract.java | 41 +++++-
.../distributed/RabbitMQWorkQueue.java | 1 +
.../distributed/TasksSerializationModule.java | 11 +-
.../distributed/RabbitMQWorkQueueSupplier.scala | 13 +-
.../eventsourcing/distributed/TaskEventDTO.scala | 19 +++
.../distributed/DistributedTaskManagerTest.java | 7 +-
.../distributed/RabbitMQWorkQueueTest.java | 125 +++++++++-------
.../distributed/TaskEventsSerializationTest.java | 12 +-
.../task/json/dto/AdditionalInformationDTO.java | 4 +
...nceWithCounterTaskAdditionalInformationDTO.java | 17 ++-
.../org/apache/james/task/MemoryTaskManager.java | 10 +-
.../apache/james/task/SerialTaskManagerWorker.java | 39 +++--
.../org/apache/james/task/TaskManagerWorker.java | 2 +
.../james/task/eventsourcing/CommandHandlers.scala | 10 +-
.../task/eventsourcing/DecisionProjection.scala | 33 +++--
.../eventsourcing/EventSourcingTaskManager.scala | 3 +-
.../apache/james/task/eventsourcing/Events.scala | 2 +
.../james/task/eventsourcing/TaskAggregate.scala | 117 ++++++++-------
.../james/task/eventsourcing/TaskCommand.scala | 2 +
.../TaskExecutionDetailsProjection.scala | 2 +
.../task/eventsourcing/WorkerStatusListener.scala | 6 +-
.../james/task/SerialTaskManagerWorkerTest.java | 52 ++++++-
.../EventSourcingTaskManagerTest.java | 3 +-
.../task/eventsourcing/TaskAggregateTest.java | 164 +++++++++++++++++++++
.../TaskExecutionDetailsProjectionContract.java | 1 -
.../james/task/TaskExecutionDetailsFixture.scala | 8 +-
94 files changed, 1270 insertions(+), 373 deletions(-)
create mode 100644
server/task/task-memory/src/test/java/org/apache/james/task/eventsourcing/TaskAggregateTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
