rename a queue

nkonev · Oct 16, 2023 · d0bdf48 · d0bdf48
1 parent 54bbe13
commit d0bdf48
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/storage/listener/rabbitmq.go b/storage/listener/rabbitmq.go
@@ -55,7 +55,7 @@ func createAndBind(name string, key string, exchange string, consumeCh *rabbitmq
 }
 
 func CreateMinioEventsChannel(connection *rabbitmq.Connection, onMessage MinioEventsListener, lc fx.Lifecycle) FanoutNotificationsChannel {
-	var queueName = "minio-file-bucket"
+	var queueName = "storage-minio-file-bucket"
 
 	return FanoutNotificationsChannel{myRabbit.CreateRabbitMqChannelWithCallback(
 		connection,