1 files changed, 10 insertions, 1 deletions
diff --git a/src/udp.c b/src/udp.c
index 470df36..26d090f 100644
--- a/src/udp.c
+++ b/src/udp.c
@@ -230,13 +230,22 @@ gboolean attach_udpsinks(struct udp_sinks *sinks)
   return TRUE;
 }
 
+static gboolean send_keepalives(gpointer user_data)
+{
+  log_printf(WARNING, "sending keep alives is not yet supporet!");
+  return TRUE;
+}
 
 gboolean attach_udpsources(struct udp_sources *sources)
 {
   if(!sources)
     return FALSE;
 
-  log_printf(WARNING, "udp source keep alive messages are not implemented yet!");
+  if(sources->keepalive_interval_ > 0) {
+    send_keepalives(sources);
+    if(!g_timeout_add_seconds(sources->keepalive_interval_, send_keepalives, sources))
+      return FALSE;
+  }
 
   return TRUE;
 }