diff --git a/internal/msggateway/init.go b/internal/msggateway/init.go index af17cff17..1e7f5d216 100644 --- a/internal/msggateway/init.go +++ b/internal/msggateway/init.go @@ -23,8 +23,8 @@ func RunWsAndServer(rpcPort, wsPort, prometheusPort int) error { return err } hubServer := NewServer(rpcPort, longServer) - longServer.SetMessageHandler(hubServer.Notification()) go hubServer.Start() + longServer.SetMessageHandler(hubServer.Notification()) go hubServer.LongConnServer.Run() wg.Wait() return nil