defer added

ayopop-tech · Jul 1, 2020 · eb6b99d · eb6b99d
1 parent b379c35
commit eb6b99d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/RMQBus.go b/RMQBus.go
@@ -66,7 +66,7 @@ func init() {
 func (RMQ *RMQ) Rpc(topic string, msg string) interface{} {
 	options := RMQ.Options
 	ch, err := RMQ.Conn.Channel()
-	//defer ch.Close()
+	defer ch.Close()
 	failOnError(err, "Failed to open a channel")
 	q, err := ch.QueueDeclare(
 		"",    // name
@@ -110,7 +110,7 @@ func (RMQ *RMQ) Rpc(topic string, msg string) interface{} {
 			res = json.Unmarshal([]byte(d.Body), &req)
 			failOnError(err, "Failed to convert body to json")
 			fmt.Println("reading done")
-			//ch.Cancel(d.ConsumerTag, true)
+			ch.Cancel(d.ConsumerTag, true)
 			break
 		}
 	}