perpetual channel bug fix wip

jrobles · Jul 19, 2018 · 9e3f322 · 9e3f322
1 parent 5de43ec
commit 9e3f322
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/producer.go b/producer.go
@@ -59,10 +59,10 @@ func Publish(conn *amqp.Connection, queue Queue, exchange Exchange, body string)
 						err = errors.New("Message not acknowledged")
 						return err
 					}
-					defer channel.Close()
 				}
 			}
 		}
 	}
+	defer channel.Close()
 	return nil
 }