Merge pull request #65 from kelchy/main

Release rmq/consumer 0.0.8
kelchy · Mar 21, 2023 · 37d9f10 · 37d9f10
2 parents 2194c6a + 053c1d0
commit 37d9f10
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/rmq/consumer/go.mod b/rmq/consumer/go.mod
@@ -1,4 +1,4 @@
-//v0.0.7
+//v0.0.8
 module github.com/kelchy/go-lib/rmq/consumer
 
 go 1.19

diff --git a/rmq/consumer/queue.go b/rmq/consumer/queue.go
@@ -7,3 +7,9 @@ func NewQueue(amqpChannel *amqp.Channel, queueConfig QueueConfig) (amqp.Queue, e
 	q, err := amqpChannel.QueueDeclare(queueConfig.Name, queueConfig.Durable, queueConfig.AutoDelete, queueConfig.Exclusive, queueConfig.NoWait, queueConfig.Args)
 	return q, err
 }
+
+// NewQueueBind binds a queue to an exchange with a routing key
+func NewQueueBind(amqpChannel *amqp.Channel, exchange string, queue, string, routingKey string, noWait bool, args amqp.Table) error {
+	queueBindErr := amqpChannel.QueueBind(queue, routingKey, exchange, false, nil)
+	return queueBindErr
+}