ensure that activity log keep alive thread is started per worker

app/lib/activity_logger.rb

@@ -18,6 +18,7 @@ class ActivityLogger
     rescue
       puts 'rescued'
       logger.close
+      ActivityLogger.unregister(id, logger)
       puts 'closed logger'
     end
   end
@@ -26,14 +27,17 @@ class ActivityLogger
     @@loggers.clear
   end
 
-  Thread.new {
+  def self.start_keep_alive_thread
-    while true
+    Thread.new {
-      event = ActivityLogEvent.new('keep-alive', nil, nil, nil)
+      while true
-      @@loggers.each_key do |key|
+        event = ActivityLogEvent.new('keep-alive', nil, nil, nil)
-        ActivityLogger.log(key, event)
+        puts "writing keep-alive"
-      end
+        @@loggers.each_key do |key|
+          ActivityLogger.log(key, event)
+        end
 
-      sleep 10
+        sleep 10
-    end
+      end
-  }
+    }
+  end
 end

config/puma.rb

@@ -25,6 +25,8 @@ on_worker_boot do
   Thread.new {
     ActivityLogSubscriber.new.start
   }
+
+  ActivityLogger.start_keep_alive_thread
 end
 
 plugin :tmp_restart