schedule watch listener refreshes

Author: rfresh2

src/main/java/vc/live/watch/WatchManager.java

@@ -45,6 +45,7 @@
 import java.util.function.Function;
 import java.util.function.Supplier;
 
+import static java.util.concurrent.TimeUnit.HOURS;
 import static vc.util.DiscordMarkdownEscape.escape;
 
 @Component
@@ -215,6 +216,23 @@ private void processChatsKeywordQueue() {
         }
     }
 
+    @Scheduled(initialDelay = 1, fixedRate = 1, timeUnit = HOURS)
+    private void refreshTopicListeners() {
+        if (!watchesEnabled) return;
+        try {
+            LOGGER.info("Refreshing watch topic listeners");
+            connectionsTopic.removeListener(connectionsTopicId);
+            connectionsTopicId = connectionsTopic.addListener(String.class, (channel, msg) -> connectionsTopicListener(msg));
+            chatsTopic.removeListener(chatsTopicId);
+            chatsTopicId = chatsTopic.addListener(String.class, (channel, msg) -> chatsTopicListener(msg));
+            deathsTopic.removeListener(deathsTopicId);
+            deathsTopicId = deathsTopic.addListener(String.class, (channel, msg) -> deathsTopicListener(msg));
+            LOGGER.info("Watch topic listeners refreshed");
+        } catch (Exception e) {
+            LOGGER.error("Failed to refresh watch topic listeners", e);
+        }
+    }
+
     private <T> void processQueue(
         String id,
         ConcurrentLinkedDeque<T> queue,