only connect broker if there are subscribers

server/grpc/grpc.go

@@ -752,6 +752,8 @@ func (g *grpcServer) Start() error {
 	g.opts.Address = ts.Addr().String()
 	g.Unlock()
 
+	// only connect if we're subscribed
+	if len(g.subscribers) > 0 {
 		// connect to the broker
 		if err := config.Broker.Connect(); err != nil {
 			return err
@@ -761,6 +763,7 @@ func (g *grpcServer) Start() error {
 		bname := config.Broker.String()
 
 		log.Logf("Broker [%s] Connected to %s", bname, baddr)
+	}
 
 	// announce self to the world
 	if err := g.Register(); err != nil {