How to Gracefully shutdown subscribers or consumeres

[khanakia]

I am using nats microservices and want to gracefull close the microservices.

how to achieve this ?

• Stop listening to any further new request
• Process the current pending request
• Gracefully shutdown or close the connection

  srv, err := micro.AddService(nc, micro.Config{
    Name:    "thewildaigo", // this has no real use just for name
    Version: "0.0.1",
  })
  
  srv.AddEndpoint(
    "ping",
    micro.HandlerFunc(func(req micro.Request) {
        time.Sleep(time.Second * 10)
        fmt.Println("test")
    }),
  )