notifier: correctly close channels after amqp delivery

this commit correctly closes the amqp channel after usage. Signed-off-by: ldelossa <ldelossa@redhat.com>
quay · Aug 24, 2020 · 717f8a0 · 717f8a0
1 parent 4d69438
commit 717f8a0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/notifier/amqp/deliverer.go b/notifier/amqp/deliverer.go
@@ -52,6 +52,7 @@ func (d *Deliverer) Deliver(ctx context.Context, nID uuid.UUID) error {
 	if err != nil {
 		return &clairerror.ErrDeliveryFailed{err}
 	}
+	defer ch.Close()
 
 	callback := d.conf.callback
 	callback.Path = path.Join(callback.Path, nID.String())

diff --git a/notifier/amqp/directdeliverer.go b/notifier/amqp/directdeliverer.go
@@ -69,6 +69,8 @@ func (d *DirectDeliverer) Deliver(ctx context.Context, _ uuid.UUID) error {
 	if err != nil {
 		return &clairerror.ErrDeliveryFailed{err}
 	}
+	defer ch.Close()
+
 	err = ch.Tx()
 	if err != nil {
 		return &clairerror.ErrDeliveryFailed{err}