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
}
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
}
func ( server * Server ) Start ( ) error { var err error service := server . service if ! service . started { rpcServer := rpc . NewServer ( ) rpcServer . Register ( service ) rpcServer . HandleHTTP ( server . path , " " + server . path ) l , e := net . Listen ( " " , server . address ) if e != nil { err = e fmt . Errorf ( " " , e ) } service . started = true service . wg . Add ( 1 ) go http . Serve ( l , nil ) } else { err = errors . New ( " " ) } return err }
// Start - starts a service for remote clients to subscribe to events
Start - starts a service for remote clients to subscribe to events