Назовите или дайте подсказку именования для временных очередей Кролика через 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))
)

Очередь создается с указанным мною именем, но это постоянная очередь. Он не удаляется при отключении процесса.

Могу ли я создать временную очередь с заданным именем или префиксом?

0 ответов

Другие вопросы по тегам