feat(broker/rabbitmq): added support passing exchange type when decla…

…ring durable exchange
micro · Dec 7, 2023 · faf6e7b · faf6e7b
1 parent 185a524
commit faf6e7b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/v4/broker/rabbitmq/channel.go b/v4/broker/rabbitmq/channel.go
@@ -107,15 +107,15 @@ func (r *rabbitMQChannel) DeclareExchange(ex Exchange) error {
 	)
 }
 
-func (r *rabbitMQChannel) DeclareDurableExchange(exchange string) error {
+func (r *rabbitMQChannel) DeclareDurableExchange(ex Exchange) error {
 	return r.channel.ExchangeDeclare(
-		exchange, // name
-		"topic",  // kind
-		true,     // durable
-		false,    // autoDelete
-		false,    // internal
-		false,    // noWait
-		nil,      // args
+		ex.Name,         // name
+		string(ex.Type), // kind
+		true,            // durable
+		false,           // autoDelete
+		false,           // internal
+		false,           // noWait
+		nil,             // args
 	)
 }
 

diff --git a/v4/broker/rabbitmq/connection.go b/v4/broker/rabbitmq/connection.go
@@ -252,7 +252,7 @@ func (r *rabbitMQConn) tryConnect(secure bool, config *amqp.Config) error {
 
 	if !r.withoutExchange {
 		if r.exchange.Durable {
-			r.Channel.DeclareDurableExchange(r.exchange.Name)
+			r.Channel.DeclareDurableExchange(r.exchange)
 		} else {
 			r.Channel.DeclareExchange(r.exchange)
 		}