fix: rabbitmq publish acknowledgement bug fixed (#189)

tanmoysrt · web-flow · commit 971b6bf76d5d · 2024-01-14T12:57:10.000+05:30
diff --git a/task_queue/remote_task_queue.go b/task_queue/remote_task_queue.go
@@ -82,12 +82,13 @@ func (r *remoteTaskQueue) EnqueueTask(queueName string, argument ArgumentType) e
 	)
 	if err != nil {
 		log.Println("error while publishing message to queue [" + queueName + "]")
+		log.Println(err.Error())
 		return errors.New("error while publishing message to queue")
 	}
 	// Check acknowledgement
-	ack := dConfirmation.Acked()
+	ack := dConfirmation.Wait()
 	if !ack {
-		log.Println("error while publishing message to queue [" + queueName + "]")
+		log.Println("error while publishing message to queue [" + queueName + "] publish ack > false")
 		return errors.New("error while publishing message to queue")
 	}
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -82,12 +82,13 @@ func (r *remoteTaskQueue) EnqueueTask(queueName string, argument ArgumentType) e`
`82`	`82`	`)`
`83`	`83`	`if err != nil {`
`84`	`84`	`log.Println("error while publishing message to queue [" + queueName + "]")`
	`85`	`+ log.Println(err.Error())`
`85`	`86`	`return errors.New("error while publishing message to queue")`
`86`	`87`	`}`
`87`	`88`	`// Check acknowledgement`
`88`		`- ack := dConfirmation.Acked()`
	`89`	`+ ack := dConfirmation.Wait()`
`89`	`90`	`if !ack {`
`90`		`- log.Println("error while publishing message to queue [" + queueName + "]")`
	`91`	`+ log.Println("error while publishing message to queue [" + queueName + "] publish ack > false")`
`91`	`92`	`return errors.New("error while publishing message to queue")`
`92`	`93`	`}`
`93`	`94`	`return nil`