consumer_graceful_stop.go

package consumer

import "time"

func (c Consumer) GracefulStop() {
	c.state.drain = true

	err := c.stanConn.Close()
	if err != nil {
		c.logger.Error().Err(err).Send()
	}
	close(c.state.done)

	time.Sleep(10 * time.Second)
}