clean pool on process shutdown

This commit is contained in:
Andre Medeiros 2022-11-02 02:21:19 -04:00
parent 2ea133966b
commit f8df346eb6

View file

@ -62,6 +62,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command {
if err != nil { if err != nil {
return err return err
} }
defer fp.Close()
mgr := faktoryworker.NewManager() mgr := faktoryworker.NewManager()
mgr.Concurrency = consumers mgr.Concurrency = consumers