These are chat archives for akkadotnet/akka.net

10th
Sep 2016
i have ported this library to .net, but it's not open sourced yet, we are actually not using streams as of now, but even the none stream version works pretty well, the api looks like bellow
var subscription = Subscription.Run(rabbitControl,
                    Channel(1, () => Consume(Binding.Direct(
                        Queue(qName, true, false, true),
                        null,
                        Exchange<Direct>.Direct("test-direct-exchange", true, true, null),
                        new List<string> { qName }),
                        BodyAs<string>(a =>
                        {
                            Console.WriteLine(a);
                            consumerResult[index].TrySetResult(a);
                            return Ack();
                        })
                        )));
                return subscription;
Boban
@bobanco
Sep 10 2016 23:04
actually the .net api version looks very similar to the scala one
and at the performance, we are right now handling arround 15-20k events/sec from rabbitmq cluster with mirrored queues
and also it fits nicely with akka.net
cuz it's build on a top of akka.net
Boban
@bobanco
Sep 10 2016 23:28
and here is how the scala api looks like
Subscription.run(rabbitControl) {
          import Directives._
          channel() {
            consume(
              Binding.direct(
                Queue(queueName, autoDelete = true),
                Exchange.direct("test-direct-exchange", autoDelete = true),
                List(queueName)
              )) {
              body(as[String]) { a =>
                consumerResult(idx).success(a)
                ack
              }
            }
          }
        }