akka - 创建 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"))

但我不确定如何将它们一起使用，如果这是正确的方法。