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