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 (7c97471 -> 0b7669b)
Date Tue, 03 Sep 2019 15:30:25 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 7c97471  JAMES-2867 Centralize jib and copy-rename-maven-plugin versions to master
pom
     new 5cafcf0  JAMES-2813 Inject TerminationSubscriber into EventSourcingTaskManager
     new 5ff6326  JAMES-2813 Add RabbitMQTerminationSubscriber
     new 0b7669b  JAMES-2813 Introduce ReactorRabbitMQChannelPool.createSender

The 3 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:
 .../rabbitmq/ReactorRabbitMQChannelPool.java       |  15 +++
 .../james/mailbox/events/RabbitMQEventBus.java     |  11 +-
 .../apache/james/DistributedTaskManagerModule.java |   4 +
 .../distributed/RabbitMQTerminationSubscriber.java | 140 ++++++++++++++++++++
 .../distributed/RabbitMQWorkQueue.java             |   9 +-
 .../distributed/DistributedTaskManagerTest.java    |  14 +-
 .../RabbitMQTerminationSubscriberTest.java         |  73 +++++++++++
 .../eventsourcing/EventSourcingTaskManager.scala   |   6 +-
 .../apache/james/task/eventsourcing/Events.scala   |   8 +-
 ...eSupplier.scala => TerminationSubscriber.scala} |  31 ++++-
 .../EventSourcingTaskManagerTest.java              |   2 +-
 ...t.java => MemoryTerminationSubscriberTest.java} |  10 +-
 .../TerminationSubscriberContract.java             | 144 +++++++++++++++++++++
 13 files changed, 427 insertions(+), 40 deletions(-)
 create mode 100644 server/task-distributed/src/main/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriber.java
 create mode 100644 server/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/RabbitMQTerminationSubscriberTest.java
 copy server/task/src/main/scala/org/apache/james/task/eventsourcing/{WorkQueueSupplier.scala
=> TerminationSubscriber.scala} (59%)
 copy server/task/src/test/java/org/apache/james/task/eventsourcing/{MemoryTaskExecutionDetailsProjectionTest.java
=> MemoryTerminationSubscriberTest.java} (84%)
 create mode 100644 server/task/src/test/java/org/apache/james/task/eventsourcing/TerminationSubscriberContract.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