akka - Alpakka と引き換えに AMQP キューを作成する

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"))

しかし、それが正しいアプローチである場合、それらを一緒に使用する方法がわかりません。