james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rouaz...@apache.org
Subject [james-project] branch master updated (c7125d4 -> fda3446)
Date Tue, 03 Sep 2019 07:34:22 GMT
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 c7125d4  MAILBOX-359 Remove no longer used classes
     new 292e6dc  JAMES-2813 Use RabbitMQWorkqueue in the distributed TaskManager test
     new 5ed834b  JAMES-2813 Implement TaskManagerContract for DistributedTaskManager
     new f6b8deb  JAMES-2813 Add DistributedTaskManagerTest cases with multiple TaskManagers
     new aaf5257  JAMES-2813 Make RabbitMQWorkQueue cluster-serialized
     new 1c8295a  JAMES-2873 Add test to ensure DistributedTaskManager track nodes correctly
     new fda3446  JAMES-2813 Fix distributed task manager runtime dependency

The 6 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/DistributedTaskManagerModule.java |  12 +-
 server/task-distributed/pom.xml                    |  20 +++
 .../distributed/RabbitMQExclusiveConsumer.java     | 174 +++++++++++++++++++++
 .../distributed/RabbitMQWorkQueue.java             | 146 +++++++++++++++++
 .../distributed/RabbitMQWorkQueueSupplier.scala}   |  21 ++-
 .../distributed/DistributedTaskManagerTest.java    | 138 ++++++++++++----
 .../distributed/RabbitMQWorkQueueTest.java         | 147 +++++++++++++++++
 .../apache/james/task/SerialTaskManagerWorker.java |  15 +-
 .../org/apache/james/task/TaskManagerWorker.java   |   2 +
 9 files changed, 627 insertions(+), 48 deletions(-)
 create mode 100644 server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQExclusiveConsumer.java
 create mode 100644 server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueue.java
 copy server/{task/src/main/scala/org/apache/james/task/eventsourcing/WorkQueueSupplier.scala
=> task-distributed/src/main/scala/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueSupplier.scala}
(55%)
 create mode 100644 server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQWorkQueueTest.java


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org


Mime
View raw message