diff --git a/internal/internal_worker.go b/internal/internal_worker.go
index 8aeaf7a44..6186389f6 100644
--- a/internal/internal_worker.go
+++ b/internal/internal_worker.go
@@ -1273,6 +1273,9 @@ func (aw *AggregatedWorker) Stop() {
 	if !util.IsInterfaceNil(aw.sessionWorker) {
 		aw.sessionWorker.Stop()
 	}
+	if !util.IsInterfaceNil(aw.nexusWorker) {
+		aw.nexusWorker.Stop()
+	}
 
 	aw.logger.Info("Stopped Worker")
 }