Декларация обменов и очередей в Akka AMQP

Question

Может быть, я просто не вижу этого, но есть ли способ объявить обмены и очереди в Akka AMQP (Scala)?

Редактировать: теперь я вижу, как объявлять обмены, но как объявлять очереди?

Answer 1

Очередь создается при создании нового потребителя.Например, если вы хотите создать очередь с именем "foobar" для использования в прямом обмене, вы создадите своего потребителя как

val consumer = AMQP.newConsumer(connection, ConsumerParameters("foobar", ...), ...)