code: func (server *Server) Start() error {
  	var err error
  	service := server.service
  	if !service.started {
  		rpcServer := rpc.NewServer()
  		rpcServer.Register(service)
  		rpcServer.HandleHTTP(server.path, "/debug"+server.path)
  		l, e := net.Listen("tcp", server.address)
  		if e != nil {
  			err = e
  			fmt.Errorf("listen error: %v", e)
  		}
  		service.started = true
  		service.wg.Add(1)
  		go http.Serve(l, nil)
  	} else {
  		err = errors.New("Server bus already started")
  	}
  	return err
  }
docs: // Start - starts a service for remote clients to subscribe to events