search

sstone / amqp-client

[THIS PROJECT HAS BEEN ARCHIVED AND IS NO LONGER MAINTAINED] Simple fault-tolerant AMQP client written in Scala and based on Akka and the RabbitMQ java client
MIT License
161 stars 88 forks source link

Exchange to Exchange Binding #66

Open SayreBladesWW opened 9 years ago

SayreBladesWW commented 9 years ago

We have a requirement to create exchange/exchange bindings: https://www.rabbitmq.com/e2e.html

It doesnt seem this is possible at the moment using this library. Could you please provide some direction?

sstone commented 9 years ago

Hello, It is not supported yet, but should be fairly easy to add. I'm travelling right now but should be able to implement this tomorrow or wednesday. If you want to give it a try, just copy how QueueBind is implemented: add an ExchangeBind message in Amqp.scala (something like case class ExchangeBind(destination: String, source: String, routing_key: String, args: Map[String, AnyRef] = Map.empty) extends Request) and handle it in ChannelOwner.scala. And don't forget to add a test to ChannelOwnerSpec.scala :)