problem: missing heartbeat options

NetMQ · Apr 25, 2020 · 22b0de0 · 22b0de0
1 parent a330c91
commit 22b0de0
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/src/FsNetMQ/Options.fs b/src/FsNetMQ/Options.fs
@@ -21,3 +21,23 @@ let setLinger (socket:Socket) (value:int<milliseconds>) =
 
 let setHelloMessage (socket:Socket) (value:byte[]) =
     socket.Socket.Options.HelloMessage <- value
+
+let heartbeatInterval (socket:Socket) = 
+    (int socket.Socket.Options.HeartbeatInterval.TotalMilliseconds) * 1<milliseconds>
+
+let setHeartbeatInterval (socket:Socket) (value:int<milliseconds>) = 
+    socket.Socket.Options.HeartbeatInterval <- TimeSpan.FromMilliseconds (float value)    
+
+let heartbeatTtl (socket:Socket) = 
+    (int socket.Socket.Options.HeartbeatTtl.TotalMilliseconds) * 1<milliseconds>
+
+let setHeartbeatTtl (socket:Socket) (value:int<milliseconds>) = 
+    socket.Socket.Options.HeartbeatTtl <- TimeSpan.FromMilliseconds (float value)    
+
+let heartbeatTimeout (socket:Socket) = 
+    (int socket.Socket.Options.HeartbeatTimeout.TotalMilliseconds) * 1<milliseconds>
+
+let setHeartbeatTimeout (socket:Socket) (value:int<milliseconds>) = 
+    socket.Socket.Options.HeartbeatTimeout <- TimeSpan.FromMilliseconds (float value)    
+
+