This is an automated email from the ASF dual-hosted git repository.
matthieu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git.
from fd77712 JAMES-2357 Docker configuration should be included for
RabbitMQMailQueue
new 83dc11f JAMES-2813 Implements a task manager using event sourcing
new f325f00 JAMES-2813 factorize scala version and bump version
new eb15e9a Merge branch 'pr-2498'
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:
mailbox/event/json/pom.xml | 57 +----------
.../scala/org/apache/james/event/json/DTOs.scala | 2 +-
.../apache/james/event/json/EventSerializer.scala | 20 ++--
pom.xml | 39 ++++++++
server/task/pom.xml | 28 +++++-
.../apache/james/task/SerialTaskManagerWorker.java | 2 +-
.../james/task/eventsourcing/CommandHandlers.scala | 82 ++++++++++++++++
.../task/eventsourcing/DecisionProjection.scala | 43 +++++++++
.../eventsourcing/EventSourcingTaskManager.scala | 105 +++++++++++++++++++++
.../apache/james/task/eventsourcing/Events.scala | 39 ++++++++
.../task/eventsourcing/RecentTasksProjection.scala | 40 ++++++++
.../eventsourcing/ScalaEventSourcingSystem.scala | 28 ++++++
.../james/task/eventsourcing/TaskAggregate.scala | 89 +++++++++++++++++
.../james/task/eventsourcing/TaskAggregateId.scala | 34 +++++++
.../james/task/eventsourcing/TaskCommand.scala | 41 ++++++++
.../TaskExecutionDetailsProjection.scala | 53 +++++++++++
.../task/eventsourcing/WorkerStatusListener.scala | 38 ++++++++
.../org/apache/james/task/TaskManagerContract.java | 6 ++
.../EventSourcingTaskManagerTest.java | 37 ++++----
19 files changed, 697 insertions(+), 86 deletions(-)
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/CommandHandlers.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/DecisionProjection.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/EventSourcingTaskManager.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/Events.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/RecentTasksProjection.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/ScalaEventSourcingSystem.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/TaskAggregate.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/TaskAggregateId.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/TaskCommand.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/TaskExecutionDetailsProjection.scala
create mode 100644
server/task/src/main/scala/org/apache/james/task/eventsourcing/WorkerStatusListener.scala
copy
mpt/impl/managesieve/cassandra/src/test/java/org/apache/james/mpt/managesieve/cassandra/CassandraManageSieveMPTTest.java
=>
server/task/src/test/java/org/apache/james/task/eventsourcing/EventSourcingTaskManagerTest.java
(63%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
