2011-11-11 3 views
1

아마 내가 보지 않을 수도 있지만 Akka AMQP (Scala)에서 교환 및 대기열을 선언 할 수있는 방법이 있습니까?Akka AMQP의 교환 및 대기열 선언

편집 : 지금 교환을 선언하는 방법을 볼 수 있지만 대기열을 선언하는 방법은 무엇입니까?

답변

0

새 소비자를 만들 때 대기열이 만들어집니다. 예를 들어 직접 교환에 사용할 "foobar"라는 대기열을 만들려면 소비자를

val consumer = AMQP.newConsumer(connection, ConsumerParameters("foobar", ...), ...) 
으로 만듭니다.