Comment and update the PubSubRouter stop method

smancke · May 18, 2016 · e8be533 · e8be533
1 parent d182e0d
commit e8be533
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/server/router.go b/server/router.go
@@ -50,7 +50,6 @@ func (router *PubSubRouter) SetAccessManager(accessManager AccessManager) {
 }
 
 func (router *PubSubRouter) Go() *PubSubRouter {
-
 	if router.accessManager == nil {
 		panic("AccessManager not set. Cannot start.")
 	}
@@ -77,11 +76,13 @@ func (router *PubSubRouter) Go() *PubSubRouter {
 			}()
 		}
 	}()
+
 	return router
 }
 
+// Stop stops the router by closing the stop channel
 func (router *PubSubRouter) Stop() error {
-	router.stop <- true
+	close(router.stop)
 	return nil
 }