Akka echangetype pour un échange de hachage cohérent de RabbitMQ

Existe-t-il un moyen d'utiliser l'échange de hachage cohérent (http://hg.rabbitmq.com/rabbitmq-consistent-hash-exchange/file/default/README.md) de RabbitMQ? avec Akka amqp? Il est facile d'utiliser Topic, direct etc. Je me demande si je peux spécifier le type d'échange pour Akka en tant que x-consistent-hash en quelque sorte. nouvelles ExchangeParameters (exchangeName: String, exchangeType: ExchangeType)Akka echangetype pour un échange de hachage cohérent de RabbitMQ

dès maintenant les ExchangeTypes pris en charge sont directs, Fanout, Match, Sujet

Source

2011-11-29 Vikas Hazrati

Il a été un moment que je l'ai écrit de Scala, mais il ne ressemble à aucun puisque ExchangeType est un trait scellé.

Si des développeurs Akka lisent ceci, c'est une bonne idée de laisser le développeur spécifier le type d'échange comme une chaîne arbitraire. Fournir des raccourcis pour les types d'échange intégrés est agréable, mais il y a beaucoup de nouveaux types d'échanges intéressants.

Source

2011-11-29 12:06:16

Ouais, c'est la clé. Le hachage cohérent est quelque chose que nous pourrions bien utiliser dans notre scénario où nous voulons arrondir les messages entrants sur plusieurs files d'attente. L'idée n'est pas d'envoyer les mêmes sur toutes les files d'attente ... –

Merci de confirmer ma décision de ne pas utiliser l'AMQP d'Akka mais d'utiliser le client Java AMQP dans mon application Akka. –

Vikas, c'est le meilleur que je peux faire pour le moment:

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

Cela signifie que je vais essayer de l'avoir dans Teh 1.3-RC2 qui sera coupée à la fin de cette la semaine.

J'ai ajouté CustomExchange (« ») et ce sera une partie de 1.3-RC2

Source

2011-11-29 15:08:58

Sure Viktor, ça sonne bien. Nous avons mis en place un tournoi à la maison pour l'instant. Refactoriserait une fois le billet ci-dessus est fermé. –

Akka echangetype pour un échange de hachage cohérent de RabbitMQ

Répondre

Questions connexes