X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Finmemory%2FShardedChatHomeServiceTest.java;h=8ed18448c27573cdd3e2fbb7dc78cb2d64b55c3e;hb=fe129c06f3a518bfadc1176d5d723c36ab5bd463;hp=b830f3004a9299fc477150d2a4a7993ca27c11c2;hpb=ec456b2c00027e54a49f3d916e89c831b2589186;p=demos%2Fkafka%2Fchat diff --git a/src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceTest.java b/src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceTest.java index b830f300..8ed18448 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceTest.java +++ b/src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/ShardedChatHomeServiceTest.java @@ -1,6 +1,7 @@ package de.juplo.kafka.chat.backend.implementation.inmemory; import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import de.juplo.kafka.chat.backend.domain.ChatHomeServiceWithShardsTest; import de.juplo.kafka.chat.backend.implementation.ShardingStrategy; import de.juplo.kafka.chat.backend.implementation.StorageStrategy; @@ -47,12 +48,22 @@ public class ShardedChatHomeServiceTest extends ChatHomeServiceWithShardsTest } @Bean - public FilesStorageStrategy storageStrategy(Clock clock) + FilesStorageStrategy storageStrategy( + Clock clock, + ObjectMapper objectMapper) { return new FilesStorageStrategy( Paths.get("target", "test-classes", "data", "files"), new KafkaLikeShardingStrategy(NUM_SHARDS), - new ObjectMapper()); + objectMapper); + } + + @Bean + ObjectMapper objectMapper() + { + ObjectMapper objectMapper = new ObjectMapper(); + objectMapper.registerModule(new JavaTimeModule()); + return objectMapper; } @Bean