call defer afte rinit.

LodestoneHQ · Nov 16, 2019 · 4c098cd · 4c098cd
1 parent 9041f05
commit 4c098cd
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/cmd/fs-publisher/fs-publisher.go b/cmd/fs-publisher/fs-publisher.go
@@ -56,11 +56,15 @@ func main() {
 					var notifyClient notify.Interface
 
 					notifyClient = new(notify.AmqpNotify)
-					notifyClient.Init(map[string]string{
+					err := notifyClient.Init(map[string]string{
 						"amqp-url": c.String("amqp-url"),
 						"exchange": c.String("amqp-exchange"),
 						"queue":    c.String("amqp-queue"),
 					})
+					if err != nil {
+						return err
+					}
+					defer notifyClient.Close()
 
 					watcher := watch.FsWatcher{}
 					watcher.Start(notifyClient, map[string]string{