diff --git a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActor.java b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActor.java
index 437b9302..2705de60 100644
--- a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActor.java
+++ b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActor.java
@@ -1,6 +1,8 @@
 package nu.marginalia.control.actor;
 
 public enum ControlActor {
+
+    MONITOR_MESSAGE_QUEUE,
     REBALANCE;
 
     public String id() {
diff --git a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java
index 2fa09ccd..50864be7 100644
--- a/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java
+++ b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/ControlActorService.java
@@ -7,6 +7,7 @@ import lombok.SneakyThrows;
 import nu.marginalia.actor.ActorStateMachine;
 import nu.marginalia.actor.prototype.ActorPrototype;
 import nu.marginalia.actor.state.ActorStateInstance;
+import nu.marginalia.control.actor.monitor.MessageQueueMonitorActor;
 import nu.marginalia.control.actor.rebalance.RebalanceActor;
 import nu.marginalia.model.gson.GsonFactory;
 import nu.marginalia.mq.MessageQueueFactory;
@@ -30,6 +31,7 @@ public class ControlActorService {
     @Inject
     public ControlActorService(MessageQueueFactory messageQueueFactory,
                                BaseServiceParams baseServiceParams,
+                               MessageQueueMonitorActor messageQueueMonitor,
                                RebalanceActor rebalanceActor
     ) {
         this.messageQueueFactory = messageQueueFactory;
@@ -37,6 +39,8 @@ public class ControlActorService {
         this.gson = GsonFactory.get();
         this.node = baseServiceParams.configuration.node();
 
+
+        register(ControlActor.MONITOR_MESSAGE_QUEUE, messageQueueMonitor);
 //        register(ControlActor.REBALANCE, rebalanceActor);
     }
 
diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/monitor/MessageQueueMonitorActor.java b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/monitor/MessageQueueMonitorActor.java
similarity index 96%
rename from code/services-core/executor-service/src/main/java/nu/marginalia/actor/monitor/MessageQueueMonitorActor.java
rename to code/services-core/control-service/src/main/java/nu/marginalia/control/actor/monitor/MessageQueueMonitorActor.java
index a6237ef9..3d47d94d 100644
--- a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/monitor/MessageQueueMonitorActor.java
+++ b/code/services-core/control-service/src/main/java/nu/marginalia/control/actor/monitor/MessageQueueMonitorActor.java
@@ -1,4 +1,4 @@
-package nu.marginalia.actor.monitor;
+package nu.marginalia.control.actor.monitor;
 
 import com.google.gson.Gson;
 import com.google.inject.Inject;
@@ -47,7 +47,4 @@ public class MessageQueueMonitorActor extends RecordActorPrototype {
         return "Periodically run maintenance tasks on the message queue";
     }
 
-
-
-
 }
diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActor.java b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActor.java
index 45edf627..a88a8ca3 100644
--- a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActor.java
+++ b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActor.java
@@ -7,7 +7,6 @@ public enum ExecutorActor {
     PROC_CONVERTER_SPAWNER,
     PROC_LOADER_SPAWNER,
     PROC_CRAWLER_SPAWNER,
-    MONITOR_MESSAGE_QUEUE,
     MONITOR_PROCESS_LIVENESS,
     MONITOR_FILE_STORAGE,
     ADJACENCY_CALCULATION,
diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java
index db784839..dd2efad7 100644
--- a/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java
+++ b/code/services-core/executor-service/src/main/java/nu/marginalia/actor/ExecutorActorControlService.java
@@ -41,7 +41,6 @@ public class ExecutorActorControlService {
                                        ConverterMonitorActor converterMonitorFSM,
                                        CrawlerMonitorActor crawlerMonitorActor,
                                        LoaderMonitorActor loaderMonitor,
-                                       MessageQueueMonitorActor messageQueueMonitor,
                                        ProcessLivenessMonitorActor processMonitorFSM,
                                        FileStorageMonitorActor fileStorageMonitorActor,
                                        IndexConstructorMonitorActor indexConstructorMonitorActor,
@@ -65,7 +64,6 @@ public class ExecutorActorControlService {
         register(ExecutorActor.PROC_LOADER_SPAWNER, loaderMonitor);
         register(ExecutorActor.PROC_CRAWLER_SPAWNER, crawlerMonitorActor);
 
-        register(ExecutorActor.MONITOR_MESSAGE_QUEUE, messageQueueMonitor);
         register(ExecutorActor.MONITOR_PROCESS_LIVENESS, processMonitorFSM);
         register(ExecutorActor.MONITOR_FILE_STORAGE, fileStorageMonitorActor);
 
diff --git a/code/services-core/executor-service/src/main/java/nu/marginalia/executor/ExecutorSvc.java b/code/services-core/executor-service/src/main/java/nu/marginalia/executor/ExecutorSvc.java
index 9cfcee50..56c5c14f 100644
--- a/code/services-core/executor-service/src/main/java/nu/marginalia/executor/ExecutorSvc.java
+++ b/code/services-core/executor-service/src/main/java/nu/marginalia/executor/ExecutorSvc.java
@@ -86,7 +86,6 @@ public class ExecutorSvc extends Service {
         logger.info("Initializing default actors");
         actorControlService.start(ExecutorActor.MONITOR_PROCESS_LIVENESS);
         actorControlService.start(ExecutorActor.MONITOR_FILE_STORAGE);
-        actorControlService.start(ExecutorActor.MONITOR_MESSAGE_QUEUE);
         actorControlService.start(ExecutorActor.PROC_CONVERTER_SPAWNER);
         actorControlService.start(ExecutorActor.PROC_CRAWLER_SPAWNER);
         actorControlService.start(ExecutorActor.PROC_INDEX_CONSTRUCTOR_SPAWNER);