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 3d30d5a JAMES-2593 expose webadmin port in docker-compose
new 0cd90e1 JAMES-2813 extract WorkQueue interface
new 4289da5 JAMES-2813 remove listener from submit task to the worker
new 0fea8c6 JAMES-2813 Rename Cassandra Task Manager into Distributed
Task Manager
new b2640dd JAMES-2813 Move TaskManagerTest to Distributed project
new 8fa086c JAMES-2813 move RabbitMQ channel pool to rabbitmq backend
project
new 673d99b JAMES-2813 Use Completed, Failed and Throwing tasks in
TaskManagerContract
new 2925baf JAMES-2813 Add MemoryReferenceTask for unit tests
new 4134cfe JAMES-2813 Add parameterized tests in TaskSerializationTest
new fd2069e JAMES-2813 Use MemoryReferenceTask in TaskManagerContract
The 9 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/rabbitmq/pom.xml | 6 +-
.../rabbitmq}/ReactorRabbitMQChannelPool.java | 6 +-
.../backend/rabbitmq}/ChannelPoolContract.java | 2 +-
.../rabbitmq}/ReactorRabbitMQChannelPoolTest.java | 3 +-
.../james/mailbox/events/RabbitMQEventBus.java | 1 +
pom.xml | 4 +-
server/container/guice/cassandra-guice/pom.xml | 9 --
.../guice/cassandra-rabbitmq-guice/pom.xml | 4 +
.../apache/james/DistributedTaskManagerModule.java | 14 +++
server/pom.xml | 2 +-
.../{task-cassandra => task-distributed}/pom.xml | 16 ++-
.../distributed}/TasksSerializationModule.java | 2 +-
.../CassandraTaskExecutionDetailsProjection.scala | 7 +-
...assandraTaskExecutionDetailsProjectionDAO.scala | 8 +-
...andraTaskExecutionDetailsProjectionModule.scala | 0
.../eventsourcing/distributed}/TaskEventDTO.scala | 2 +-
...andraTaskExecutionDetailsProjectionDAOTest.java | 1 +
...assandraTaskExecutionDetailsProjectionTest.java | 2 +
.../distributed/DistributedTaskManagerTest.java} | 33 ++++--
.../distributed}/TaskEventsSerializationTest.java | 2 +-
server/task-json/pom.xml | 5 +
.../server/task/json/TaskSerializationTest.java | 71 +++++++-----
...tedTaskDTO.java => MemoryReferenceTaskDTO.java} | 10 +-
.../task/json/dto/MemoryReferenceTaskStore.java} | 30 ++++-
.../server/task/json/dto/TestTaskDTOModules.java | 12 ++
.../org/apache/james/task/MemoryTaskManager.java | 45 ++++----
.../task/{WorkQueue.java => MemoryWorkQueue.java} | 29 ++---
.../apache/james/task/SerialTaskManagerWorker.java | 24 ++--
.../org/apache/james/task/TaskManagerWorker.java | 12 +-
.../main/java/org/apache/james/task/WorkQueue.java | 62 +----------
.../eventsourcing/EventSourcingTaskManager.scala | 47 ++++----
.../task/eventsourcing/WorkQueueSupplier.scala | 20 ++--
.../task/eventsourcing/WorkerStatusListener.scala | 46 ++++----
...{ThrowingTask.java => MemoryReferenceTask.java} | 12 +-
.../james/task/SerialTaskManagerWorkerTest.java | 42 +++----
.../org/apache/james/task/TaskManagerContract.java | 124 ++++++++++-----------
.../EventSourcingTaskManagerTest.java | 10 +-
37 files changed, 386 insertions(+), 339 deletions(-)
rename
{mailbox/event/event-rabbitmq/src/main/java/org/apache/james/mailbox/events =>
backends-common/rabbitmq/src/main/java/org/apache/james/backend/rabbitmq}/ReactorRabbitMQChannelPool.java
(96%)
rename
{mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events =>
backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq}/ChannelPoolContract.java
(98%)
rename
{mailbox/event/event-rabbitmq/src/test/java/org/apache/james/mailbox/events =>
backends-common/rabbitmq/src/test/java/org/apache/james/backend/rabbitmq}/ReactorRabbitMQChannelPoolTest.java
(97%)
rename server/container/guice/{cassandra-guice/src/test =>
cassandra-rabbitmq-guice/src/main}/java/org/apache/james/DistributedTaskManagerModule.java
(72%)
rename server/{task-cassandra => task-distributed}/pom.xml (89%)
rename
server/{task-cassandra/src/main/java/org/apache/james/task/eventsourcing/cassandra
=>
task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed}/TasksSerializationModule.java
(98%)
rename server/{task-cassandra =>
task-distributed}/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjection.scala
(97%)
rename server/{task-cassandra =>
task-distributed}/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionDAO.scala
(99%)
rename server/{task-cassandra =>
task-distributed}/src/main/scala/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionModule.scala
(100%)
rename
server/{task-cassandra/src/main/scala/org/apache/james/task/eventsourcing/cassandra
=>
task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed}/TaskEventDTO.scala
(99%)
rename server/{task-cassandra =>
task-distributed}/src/test/java/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionDAOTest.java
(98%)
rename server/{task-cassandra =>
task-distributed}/src/test/java/org/apache/james/task/eventsourcing/cassandra/CassandraTaskExecutionDetailsProjectionTest.java
(94%)
rename
server/{container/guice/cassandra-guice/src/test/java/org/apache/james/CassandraTaskManagerTest.java
=>
task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java}
(86%)
rename
server/{task-cassandra/src/test/java/org/apache/james/task/eventsourcing/cassandra
=>
task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed}/TaskEventsSerializationTest.java
(98%)
copy
server/task-json/src/test/java/org/apache/james/server/task/json/dto/{CompletedTaskDTO.java
=> MemoryReferenceTaskDTO.java} (81%)
copy
server/{task/src/test/java/org/apache/james/task/eventsourcing/MemoryTaskExecutionDetailsProjectionTest.java
=>
task-json/src/test/java/org/apache/james/server/task/json/dto/MemoryReferenceTaskStore.java}
(60%)
copy server/task/src/main/java/org/apache/james/task/{WorkQueue.java =>
MemoryWorkQueue.java} (70%)
copy
mailbox/elasticsearch/src/main/java/org/apache/james/mailbox/elasticsearch/json/SerializableMessage.java
=>
server/task/src/main/scala/org/apache/james/task/eventsourcing/WorkQueueSupplier.scala
(65%)
copy server/task/src/test/java/org/apache/james/task/{ThrowingTask.java =>
MemoryReferenceTask.java} (86%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
