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: [email protected]
For additional commands, e-mail: [email protected]
