Fix unit test

LGouellec · Oct 1, 2024 · f8e5bf4 · f8e5bf4
1 parent d9c7505
commit f8e5bf4
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/test/Streamiz.Kafka.Net.Tests/Stores/BoundMemoryRocksDbConfigHandlerTests.cs b/test/Streamiz.Kafka.Net.Tests/Stores/BoundMemoryRocksDbConfigHandlerTests.cs
@@ -8,6 +8,7 @@
 using Streamiz.Kafka.Net.Table;
 using Moq;
 using Streamiz.Kafka.Net.Crosscutting;
+using Streamiz.Kafka.Net.Metrics;
 using Streamiz.Kafka.Net.Processors;
 using Streamiz.Kafka.Net.Processors.Internal;
 using Streamiz.Kafka.Net.SerDes;
@@ -35,6 +36,8 @@ byte[] Value(Int32 number)
         var config = new StreamConfig();
         config.RocksDbConfigHandler = handler.Handle;
 
+        var metricsRegistry = new StreamMetricsRegistry();
+
         var stateManager = new Mock<IStateManager>();
         stateManager.Setup(s => 
             s.Register(It.IsAny<IStateStore>(), It.IsAny<Action<ConsumeResult<byte[], byte[]>>>()));
@@ -46,6 +49,8 @@ byte[] Value(Int32 number)
             .Returns("./bound-test/");
         context.Setup(c => c.Configuration)
             .Returns(config);
+        context.Setup(c => c.Metrics)
+            .Returns(() => metricsRegistry);
         context.Setup(c => c.States)
             .Returns(() => stateManager.Object);