Назовите или дайте подсказку именования для временных очередей Кролика через Alpakka
Я могу создать временную очередь на обмен:
val queueSettings = TemporaryQueueSourceSettings(
AmqpUriConnectionProvider(amqpUri),
exchange
)
val source = AmqpSource.atMostOnceSource(queueSettings, bufferSize = 10)
Очередь создается со случайным именем, например amq.gen-JMAFhPqw_wcTy5BbgAMD8g
и удаляется после завершения работы приложения.
Поскольку созданные очереди среди многих подключены к одному и тому же обмену, я бы хотел назначить имя или префикс в очередь.
Я попробовал следующее:
val queueName = s"myapp-${env}-${Random.alphanumeric.take(10).mkString}"
val queueSettings = TemporaryQueueSourceSettings(
AmqpUriConnectionProvider(amqpUri),
exchange,
declarations = Seq(QueueDeclaration(queueName, autoDelete = true))
)
Очередь создается с указанным мною именем, но это постоянная очередь. Он не удаляется при отключении процесса.
Могу ли я создать временную очередь с заданным именем или префиксом?