Akka echangetype для последовательного обмена хэшем RabbitMQ

Question

Есть ли способ использовать согласованный обмен хешами (http://hg.rabbitmq.com/rabbitmq-consistent-hash-exchange/file/default/README.md) RabbitMQ с Akka amqp? Легко использовать Topic, direct и т. Д. Мне интересно, могу ли я указать тип обмена для Akka как x-compatibility-хэш как-то. новые ExchangeParameters (exchangeName: String, exchangeType: ExchangeType)

прямо сейчас поддерживаемые типы ExchangeType: Direct, Fanout, Match, Topic

Answer 1

Викас, это лучшее, что я могу сделать на данный момент:

https://www.assembla.com/spaces/akka/tickets/1413-support-custom-exchange-types-in-akka-amqp

Это означает, что я попытаюсь включить его в 1.3-RC2, который будет вырезан в конце этой недели.

Я добавил CustomExchange (""), и он будет частью 1.3-RC2

Answer 2

Прошло много времени с тех пор, как я написал Scala, но похоже, что нет, поскольку ExchangeType - это запечатанная черта.

Если кто-то из разработчиков Akka читает это, то очень хорошая идея позволить разработчику указать тип обмена в виде произвольной строки. Предоставлять короткие пути для встроенных типов обмена - это хорошо, но появляется множество интересных новых типов обмена.