X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/57170c25230cf56c99c5b2cbc795f4599cbda87f..091c92aef16f9657cf7b9eb8f8778aafa33f12c1:/services/ws/main.go

diff --git a/services/ws/main.go b/services/ws/main.go
index 7c3625bdad..9eee8130af 100644
--- a/services/ws/main.go
+++ b/services/ws/main.go
@@ -54,9 +54,11 @@ func main() {
 			newPermChecker: func() permChecker { return newPermChecker(cfg.Client) },
 		},
 	}
-	// Bootstrap the eventSource by attaching a dummy subscriber
-	// and hanging up.
-	eventSource.NewSink().Stop()
+
+	go func() {
+		eventSource.Run()
+		log.Fatal("event source stopped")
+	}()
 
 	if _, err := daemon.SdNotify(false, "READY=1"); err != nil {
 		log.WithError(err).Warn("error notifying init daemon")