You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jun 11, 2021. It is now read-only.
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 :)
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?
The text was updated successfully, but these errors were encountered: