From d662c930c4ec7a97c1d914ee3918c56f5da0d5a7 Mon Sep 17 00:00:00 2001 From: Xuan Hao Date: Tue, 21 Mar 2023 16:59:46 +0800 Subject: [PATCH] added queue bind func --- rmq/consumer/go.mod | 2 +- rmq/consumer/queue.go | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/rmq/consumer/go.mod b/rmq/consumer/go.mod index b269342..6314fb2 100644 --- 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 index 7b24940..d68c552 100644 --- 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 +}