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 6e0f2c3 JAMES-3062: EventDeadLetters healthCheck
new aa54339 JAMES-3009 convert to scala cassandra event store
new b9d6d77 JAMES-3009 convert to scala event-store-api
new 739f5a1 JAMES-3009 convert to scala event-sourcing-pojo
new 9db5a36 JAMES-3009 convert to scala event sourcing core
new 3df117d JAMES-3009 convert to scala JsonEventSerializer
new edec474 JAMES-3009 make code in event sourcing pojo more idiomatic to
scala
new 929e958 JAMES-3009 convert event sourcing core tests to scala
new ff80626 JAMES-3009 convert cassandra event store test to scala
new a41c5d0 JAMES-3009 convert event store api tests to scala
new 2a8c675 JAMES-3009 convert event sourcing pojo tests to scala
new b18869e JAMES-3009 convert event store memory tests to scala
new 610f268 JAMES-3009 remove factory method with java.util.List in
History
new ff8784c JAMES-3009 fix licence format
new d30cc4a Provide java method for getting the events in History
The 14 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:
event-sourcing/event-sourcing-core/pom.xml | 17 +-
.../james/eventsourcing/CommandDispatcher.java | 110 ---------
.../apache/james/eventsourcing/CommandHandler.java | 12 +-
.../org/apache/james/eventsourcing/EventBus.java | 64 ------
.../eventsourcing/javaapi/CommandHandlerJava.java} | 27 +--
.../james/eventsourcing/CommandDispatcher.scala | 92 ++++++++
.../org/apache/james/eventsourcing/EventBus.scala} | 39 ++--
.../james/eventsourcing/EventSourcingSystem.scala} | 35 +--
.../apache/james/eventsourcing/Subscriber.scala} | 14 +-
.../eventsourcing/EventSourcingSystemTest.java | 252 ---------------------
.../eventsourcing/DataCollectorSubscriber.scala} | 15 +-
.../eventsourcing/EventSourcingSystemTest.scala | 167 ++++++++++++++
event-sourcing/event-sourcing-pojo/pom.xml | 16 ++
.../org/apache/james/eventsourcing/EventId.java | 86 -------
.../apache/james/eventsourcing/AggregateId.scala} | 12 +-
.../org/apache/james/eventsourcing/Command.scala} | 10 +-
.../org/apache/james/eventsourcing/Event.scala} | 29 ++-
.../org/apache/james/eventsourcing/EventId.scala} | 35 ++-
.../apache/james/eventsourcing/EventIdTest.java | 84 -------
.../org/apache/james/eventsourcing/TestEvent.java | 82 -------
.../apache/james/eventsourcing/EventIdTest.scala | 68 ++++++
.../james/eventsourcing/TestAggregateId.scala} | 11 +-
.../apache/james/eventsourcing/TestEvent.scala} | 18 +-
event-sourcing/event-store-api/pom.xml | 17 +-
.../eventstore/EventStoreFailedException.java | 26 ---
.../james/eventsourcing/eventstore/History.java | 94 --------
.../eventsourcing/eventstore/EventStore.scala} | 38 ++--
.../eventstore/EventStoreFailedException.scala} | 9 +-
.../james/eventsourcing/eventstore/History.scala} | 67 +++---
.../eventsourcing/eventstore/EventStoreTest.java | 88 -------
.../eventsourcing/eventstore/HistoryTest.java | 90 --------
.../eventstore/EventStoreContract.scala | 82 +++++++
.../eventsourcing/eventstore/HistoryTest.scala | 55 +++++
event-sourcing/event-store-cassandra/pom.xml | 21 ++
.../eventstore/cassandra/CassandraEventStore.java | 64 ------
.../cassandra/CassandraEventStoreTable.java | 27 ---
.../eventstore/cassandra/EventNestedTypes.java} | 7 +-
.../eventstore/cassandra/EventStoreDao.java | 113 ---------
.../eventstore/cassandra/JsonEventSerializer.java | 109 ---------
.../cassandra/CassandraEventStore.scala} | 37 +--
.../cassandra/CassandraEventStoreModule.scala} | 35 ++-
.../cassandra/CassandraEventStoreTable.scala} | 14 +-
.../eventstore/cassandra/EventStoreDao.scala | 81 +++++++
.../eventstore/cassandra/JsonEventSerializer.scala | 87 +++++++
.../eventstore/cassandra/dto/EventDTO.scala} | 6 +-
.../eventstore/cassandra/dto/EventDTOModule.scala} | 29 ++-
.../CassandraEventSourcingSystemTest.java | 29 ---
.../cassandra/CassandraEventStoreExtension.java | 77 -------
.../cassandra/CassandraEventStoreTest.java | 29 ---
.../cassandra/JsonEventSerializerTest.java | 123 ----------
.../eventstore/cassandra/dto/OtherEvent.java | 50 ----
.../cassandra/dto/OtherTestEventDTO.java | 70 ------
.../eventstore/cassandra/dto/TestEventDTO.java | 71 ------
.../cassandra/dto/TestEventDTOModules.java | 51 -----
.../CassandraEventSourcingSystemTest.scala} | 11 +-
.../cassandra/CassandraEventStoreExtension.scala | 57 +++++
...assandraEventStoreExtensionForTestEvents.scala} | 10 +-
.../cassandra/CassandraEventStoreTest.scala} | 11 +-
.../cassandra/JsonEventSerializerTest.scala | 95 ++++++++
.../eventstore/cassandra/dto/OtherEvent.scala} | 14 +-
.../cassandra/dto/OtherTestEventDTO.scala} | 39 ++--
.../eventstore/cassandra/dto/TestEventDTO.scala} | 33 +--
.../cassandra/dto/TestEventDTOModules.scala} | 40 ++--
.../eventstore/memory/InMemoryEventStore.scala | 20 +-
.../memory/InMemoryEventStoreExtension.java | 39 ----
.../memory/InMemoryEventSourcingSystemTest.scala} | 11 +-
.../memory/InMemoryEventStoreExtension.scala} | 27 +--
.../memory/InMemoryEventStoreTest.scala} | 13 +-
.../apache/james/json/JsonGenericSerializer.java | 4 +-
.../apache/james/JsonGenericSerializerTest.java | 6 +-
.../apache/james/event/json/EventSerializer.scala | 10 +-
.../mailing/aggregates/UserQuotaThresholds.java | 3 +-
.../commands/DetectThresholdCrossingHandler.java | 6 +-
.../listeners/QuotaThresholdCrossingListener.java | 5 +-
.../org/apache/james/CassandraJamesServerMain.java | 5 +-
.../data/CassandraDLPConfigurationStoreModule.java | 4 +-
.../james/modules/data/CassandraJmapModule.java | 4 +-
.../eventstore/CassandraEventStoreModule.java | 6 +-
.../mailbox/CassandraQuotaMailingModule.java | 4 +-
.../james/modules/TaskSerializationModule.java | 129 +++++------
.../james/modules/rabbitmq/RabbitMQModule.java | 4 +-
...ventSourcingDLPConfigurationStoreExtension.java | 2 +-
.../filtering/impl/DefineRulesCommandHandler.java | 6 +-
.../impl/EventSourcingFilteringManagement.java | 2 +-
.../api/filtering/impl/FilteringAggregate.java | 2 +-
.../EventSourcingDLPConfigurationStore.java | 2 +-
.../aggregates/DLPDomainConfiguration.java | 2 +-
.../commands/ClearCommandHandler.java | 6 +-
.../commands/StoreCommandHandler.java | 6 +-
.../configuration/ConfigurationAggregate.java | 2 +-
.../EventsourcingConfigurationManagement.java | 2 +-
.../RegisterConfigurationCommandHandler.java | 6 +-
.../RabbitMQMailQueueConfigurationChangeTest.java | 2 +-
.../queue/rabbitmq/RabbitMQMailQueueTest.java | 2 +-
.../EventsourcingConfigurationManagementTest.java | 7 +-
.../distributed/TasksSerializationModule.java | 16 +-
.../CassandraTaskExecutionDetailsProjection.scala | 13 +-
...assandraTaskExecutionDetailsProjectionDAO.scala | 6 +-
...andraTaskExecutionDetailsProjectionModule.scala | 6 +-
.../eventsourcing/distributed/TaskEventDTO.scala | 16 +-
...assandraTaskExecutionDetailsProjectionTest.java | 6 +-
.../distributed/DistributedTaskManagerTest.java | 6 +-
.../RabbitMQTerminationSubscriberTest.java | 3 +-
.../distributed/TaskEventsSerializationTest.java | 6 +-
.../JsonTaskAdditionalInformationSerializer.java | 4 +-
.../james/server/task/json/JsonTaskSerializer.java | 2 +-
.../james/task/eventsourcing/CommandHandlers.scala | 14 +-
.../eventsourcing/EventSourcingTaskManager.scala | 4 +-
.../eventsourcing/ScalaEventSourcingSystem.scala | 28 ---
.../james/task/eventsourcing/TaskAggregate.scala | 48 ++--
.../TaskExecutionDetailsProjection.scala | 2 +-
.../task/eventsourcing/TerminationSubscriber.scala | 11 +-
.../EventSourcingTaskManagerTest.java | 6 +-
.../task/eventsourcing/TaskAggregateTest.java | 25 +-
.../TerminationSubscriberContract.java | 2 +-
115 files changed, 1436 insertions(+), 2438 deletions(-)
delete mode 100644
event-sourcing/event-sourcing-core/src/main/java/org/apache/james/eventsourcing/CommandDispatcher.java
delete mode 100644
event-sourcing/event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventBus.java
copy
event-sourcing/{event-sourcing-pojo/src/main/java/org/apache/james/eventsourcing/Event.java
=>
event-sourcing-core/src/main/java/org/apache/james/eventsourcing/javaapi/CommandHandlerJava.java}
(69%)
create mode 100644
event-sourcing/event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/CommandDispatcher.scala
copy
event-sourcing/event-sourcing-core/src/main/{java/org/apache/james/eventsourcing/EventSourcingSystem.java
=> scala/org/apache/james/eventsourcing/EventBus.scala} (54%)
rename
event-sourcing/{event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/EventDTOModule.java
=>
event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/EventSourcingSystem.scala}
(55%)
copy
event-sourcing/{event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/EventDTO.java
=>
event-sourcing-core/src/main/scala/org/apache/james/eventsourcing/Subscriber.scala}
(79%)
delete mode 100644
event-sourcing/event-sourcing-core/src/test/java/org/apache/james/eventsourcing/EventSourcingSystemTest.java
rename
event-sourcing/{event-store-memory/src/test/java/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventSourcingSystemTest.java
=>
event-sourcing-core/src/test/scala/org/apache/james/eventsourcing/DataCollectorSubscriber.scala}
(74%)
create mode 100644
event-sourcing/event-sourcing-core/src/test/scala/org/apache/james/eventsourcing/EventSourcingSystemTest.scala
delete mode 100644
event-sourcing/event-sourcing-pojo/src/main/java/org/apache/james/eventsourcing/EventId.java
copy
event-sourcing/event-sourcing-pojo/src/main/{java/org/apache/james/eventsourcing/Command.java
=> scala/org/apache/james/eventsourcing/AggregateId.scala} (82%)
copy
event-sourcing/event-sourcing-pojo/src/main/{java/org/apache/james/eventsourcing/Command.java
=> scala/org/apache/james/eventsourcing/Command.scala} (84%)
rename
event-sourcing/{event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/EventDTO.java
=>
event-sourcing-pojo/src/main/scala/org/apache/james/eventsourcing/Event.scala}
(59%)
rename
event-sourcing/{event-sourcing-core/src/test/java/org/apache/james/eventsourcing/DataCollectorSubscriber.java
=>
event-sourcing-pojo/src/main/scala/org/apache/james/eventsourcing/EventId.scala}
(66%)
delete mode 100644
event-sourcing/event-sourcing-pojo/src/test/java/org/apache/james/eventsourcing/EventIdTest.java
delete mode 100644
event-sourcing/event-sourcing-pojo/src/test/java/org/apache/james/eventsourcing/TestEvent.java
create mode 100644
event-sourcing/event-sourcing-pojo/src/test/scala/org/apache/james/eventsourcing/EventIdTest.scala
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-sourcing-pojo/src/test/scala/org/apache/james/eventsourcing/TestAggregateId.scala}
(76%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/CommandHandler.java
=>
event-sourcing-pojo/src/test/scala/org/apache/james/eventsourcing/TestEvent.scala}
(66%)
delete mode 100644
event-sourcing/event-store-api/src/main/java/org/apache/james/eventsourcing/eventstore/EventStoreFailedException.java
delete mode 100644
event-sourcing/event-store-api/src/main/java/org/apache/james/eventsourcing/eventstore/History.java
rename
event-sourcing/{event-sourcing-pojo/src/main/java/org/apache/james/eventsourcing/Event.java
=>
event-store-api/src/main/scala/org/apache/james/eventsourcing/eventstore/EventStore.scala}
(56%)
rename
event-sourcing/{event-sourcing-pojo/src/main/java/org/apache/james/eventsourcing/AggregateId.java
=>
event-store-api/src/main/scala/org/apache/james/eventsourcing/eventstore/EventStoreFailedException.scala}
(84%)
rename
event-sourcing/{event-sourcing-pojo/src/test/java/org/apache/james/eventsourcing/TestAggregateId.java
=>
event-store-api/src/main/scala/org/apache/james/eventsourcing/eventstore/History.scala}
(54%)
delete mode 100644
event-sourcing/event-store-api/src/test/java/org/apache/james/eventsourcing/eventstore/EventStoreTest.java
delete mode 100644
event-sourcing/event-store-api/src/test/java/org/apache/james/eventsourcing/eventstore/HistoryTest.java
create mode 100644
event-sourcing/event-store-api/src/test/scala/org/apache/james/eventsourcing/eventstore/EventStoreContract.scala
create mode 100644
event-sourcing/event-store-api/src/test/scala/org/apache/james/eventsourcing/eventstore/HistoryTest.scala
delete mode 100644
event-sourcing/event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStore.java
delete mode 100644
event-sourcing/event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreTable.java
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/EventNestedTypes.java}
(87%)
delete mode 100644
event-sourcing/event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.java
delete mode 100644
event-sourcing/event-store-cassandra/src/main/java/org/apache/james/eventsourcing/eventstore/cassandra/JsonEventSerializer.java
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventSourcingSystem.java
=>
event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStore.scala}
(53%)
rename
event-sourcing/event-store-cassandra/src/main/{java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.java
=>
scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.scala}
(60%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreTable.scala}
(80%)
create mode 100644
event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/EventStoreDao.scala
create mode 100644
event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/JsonEventSerializer.scala
rename
event-sourcing/{event-sourcing-pojo/src/main/java/org/apache/james/eventsourcing/Command.java
=>
event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/EventDTO.scala}
(90%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventSourcingSystem.java
=>
event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/EventDTOModule.scala}
(57%)
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventSourcingSystemTest.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreExtension.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreTest.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/JsonEventSerializerTest.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/OtherEvent.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/OtherTestEventDTO.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/TestEventDTO.java
delete mode 100644
event-sourcing/event-store-cassandra/src/test/java/org/apache/james/eventsourcing/eventstore/cassandra/dto/TestEventDTOModules.java
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventSourcingSystemTest.scala}
(74%)
create mode 100644
event-sourcing/event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreExtension.scala
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreExtensionForTestEvents.scala}
(72%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreTest.scala}
(75%)
create mode 100644
event-sourcing/event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/JsonEventSerializerTest.scala
rename
event-sourcing/{event-store-memory/src/test/java/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventStoreTest.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/OtherEvent.scala}
(69%)
rename
event-sourcing/{event-store-api/src/main/java/org/apache/james/eventsourcing/eventstore/EventStore.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/OtherTestEventDTO.scala}
(58%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventSourcingSystem.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/TestEventDTO.scala}
(52%)
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventSourcingSystem.java
=>
event-store-cassandra/src/test/scala/org/apache/james/eventsourcing/eventstore/cassandra/dto/TestEventDTOModules.scala}
(52%)
delete mode 100644
event-sourcing/event-store-memory/src/test/java/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventStoreExtension.java
copy
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-memory/src/test/scala/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventSourcingSystemTest.scala}
(75%)
rename
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/EventSourcingSystem.java
=>
event-store-memory/src/test/scala/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventStoreExtension.scala}
(59%)
rename
event-sourcing/{event-sourcing-core/src/main/java/org/apache/james/eventsourcing/Subscriber.java
=>
event-store-memory/src/test/scala/org/apache/james/eventsourcing/eventstore/memory/InMemoryEventStoreTest.scala}
(71%)
delete mode 100644
server/task/task-memory/src/main/scala/org/apache/james/task/eventsourcing/ScalaEventSourcingSystem.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org
