You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2020/05/13 12:07:18 UTC
[james-project] 09/15: JAMES-3172 DistributedTaskManagerTest: Event
serializer need to handle nested types
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit ba939ee204f82e8ce516122ced65827cca4ddd0a
Author: Benoit Tellier <bt...@linagora.com>
AuthorDate: Fri May 8 05:59:13 2020 +0200
JAMES-3172 DistributedTaskManagerTest: Event serializer need to handle nested types
---
.../eventsourcing/distributed/DistributedTaskManagerTest.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
index 0b1ab59..db84283 100644
--- a/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
+++ b/server/task/task-distributed/src/test/java/org/apache/james/task/eventsourcing/distributed/DistributedTaskManagerTest.java
@@ -80,6 +80,7 @@ import org.junit.jupiter.api.extension.RegisterExtension;
import com.google.common.collect.ImmutableBiMap;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Sets;
+
import reactor.rabbitmq.Sender;
class DistributedTaskManagerTest implements TaskManagerContract {
@@ -169,7 +170,11 @@ class DistributedTaskManagerTest implements TaskManagerContract {
this.workQueueSupplier = new TrackedRabbitMQWorkQueueSupplier(rabbitMQExtension.getSender(), rabbitMQExtension.getReceiverProvider(), taskSerializer);
this.eventStore = eventStore;
this.terminationSubscribers = new ArrayList<>();
- this.eventSerializer = JsonEventSerializer.forModules(eventDtoModule).withoutNestedType();
+ this.eventSerializer = JsonEventSerializer.forModules(eventDtoModule)
+ .withNestedTypeModules(
+ Sets.union(
+ ImmutableSet.of(ADDITIONAL_INFORMATION_MODULE),
+ taskDTOModules));
}
@AfterEach
@@ -183,7 +188,9 @@ class DistributedTaskManagerTest implements TaskManagerContract {
}
EventSourcingTaskManager taskManager(Hostname hostname) {
- RabbitMQTerminationSubscriber terminationSubscriber = new RabbitMQTerminationSubscriber(rabbitMQExtension.getSender(), rabbitMQExtension.getReceiverProvider(), eventSerializer);
+ RabbitMQTerminationSubscriber terminationSubscriber = new RabbitMQTerminationSubscriber(rabbitMQExtension.getSender(),
+ rabbitMQExtension.getReceiverProvider(),
+ eventSerializer);
terminationSubscribers.add(terminationSubscriber);
terminationSubscriber.start();
return new EventSourcingTaskManager(workQueueSupplier, eventStore, executionDetailsProjection, hostname, terminationSubscriber);
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org