Создать очередь AMQP в обмен на Alpakka

Question

Я хочу создать очередь в существующем обмене для чтения.

Другое приложение публикует сообщения для этого обмена и распределяет их по всем очередям участников. Я хочу, чтобы мое новое приложение стало дополнительным подписчиком этих сообщений.

Следующее создает очередь:

implicit val system = ActorSystem("my-system")
implicit val materializer = ActorMaterializer()
implicit val executionCtx: ExecutionContext = system.dispatcher

val queueName: String = s"test-queue-${System.currentTimeMillis}"
val queueDeclaration = QueueDeclaration(queueName, autoDelete = true)
val amqpSource = AmqpSource(
    NamedQueueSourceSettings(AmqpConnectionUri(amqpUri), queueName)
      .withDeclarations(queueDeclaration), bufferSize = 10)

И это создает раковину для обмена

val sink = AmqpSink.simple(AmqpSinkSettings(AmqpConnectionUri(amqpUri))
  .withExchange("exchange_name"))

Но я не уверен, как использовать их вместе, если это правильный подход.