publish with correct routing key

ochom · Oct 23, 2024 · 589d876 · 589d876
1 parent 6139cbc
commit 589d876
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 228 deletions.
diff --git a/pubsub/publisher.go b/pubsub/publisher.go
@@ -125,10 +125,10 @@ func (p *publisher) publish(body []byte, delay time.Duration) error {
 
 	// publish message to exchange
 	err = channel.Publish(
-		p.exchange, // exchange
-		"",         // routing key
-		true,       // mandatory
-		false,      // immediate
+		p.exchange,   // exchange
+		p.routingKey, // routing key
+		true,         // mandatory
+		false,        // immediate
 		amqp.Publishing{
 			ContentType:  "application/json",
 			Body:         body,

diff --git a/quickmq/client.go b/quickmq/client.go
diff --git a/quickmq/client_test.go b/quickmq/client_test.go
diff --git a/quickmq/quickmq.go b/quickmq/quickmq.go