Function ExampleWithEndpointSubject

micro/example_test.go:95–121

()

}

func ExampleWithEndpointSubject() {
	nc, err := nats.Connect("127.0.0.1:4222")
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

	echoHandler := func(req micro.Request) {
		req.Respond(req.Data())
	}

	config := micro.Config{
		Name:    "EchoService",
		Version: "1.0.0",
	}

	srv, err := micro.AddService(nc, config)
	if err != nil {
		log.Fatal(err)
	}

	// endpoint will be registered under "service.echo" subject
	err = srv.AddEndpoint("Echo", micro.HandlerFunc(echoHandler), micro.WithEndpointSubject("service.echo"))
	if err != nil {
		log.Fatal(err)
	}
}

func ExampleService_AddGroup() {
	nc, err := nats.Connect("127.0.0.1:4222")