Goroutine leak async consumer fixes #231

Signed-off-by: Sotirios Mantziaris <s.mantziaris@thebeat.co>
mantzas · Oct 25, 2018 · 9cc72d4 · 9cc72d4
1 parent 0fcaed6
commit 9cc72d4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/async/component.go b/async/component.go
@@ -96,6 +96,7 @@ func (c *Component) processing(ctx context.Context) error {
 	if err != nil {
 		return errors.Wrap(err, "failed to create consumer")
 	}
+	defer cns.Close()
 	c.info["consumer"] = cns.Info()
 
 	chMsg, chErr, err := cns.Consume(ctx)