fix listen queue logic, to also clear temporary queue after purge

tomatool · Jul 30, 2018 · ecfe0ea · ecfe0ea
1 parent 4e70918
commit ecfe0ea
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/resource/queue/rabbitmq/rabbitmq.go b/resource/queue/rabbitmq/rabbitmq.go
@@ -82,6 +82,9 @@ func (c *rabbitMQ) Listen(target string) error {
 	if _, err := ch.QueuePurge(q.Name, false); err != nil {
 		return err
 	}
+	if _, ok := c.consumedMessage[target]; ok {
+		c.consumedMessage[target] = make([][]byte, 0)
+	}
 
 	msgs, err := consume(ch, q.Name)
 	if err != nil {