v1.0.0-rc.62

2025-07-08 20:19:59 +02:00
parent 02039b9f1c
commit 0b5f28f50d
150 changed files with 197 additions and 163 deletions
@@ -4,10 +4,14 @@
 #include "ZMQPreviewSocket.h"
 #include "../common/Definitions.h"

-ZMQPreviewSocket::ZMQPreviewSocket(const std::string &addr)
+ZMQPreviewSocket::ZMQPreviewSocket(const std::string &addr, const std::optional<int32_t> &watermark)
    : socket(ZMQSocketType::Pub),
      counter(std::chrono::seconds(1)) {
-    socket.Conflate(true);
+    if (!watermark || watermark <= 0)
+        socket.Conflate(true);
+    else
+        socket.SendWaterMark(watermark.value());
+
    socket.SendTimeout(std::chrono::milliseconds(100));
    socket.Bind(addr);
 }