ReactiveQueue Example: Increasing Throughput for Stateless WCF services


Code for this post is available here As promised, here is an example of how to use the ReactiveQueue<T> from RxContrib.  Imagine that you have a stateless WCF service that needs to handle a large number of client requests – perhaps, a distributed logging service.  Clients need to send messages as quickly as possible and then be on their way.  It is up to your service to then do something with those messages.  So, assuming we have a logging service, we know several things at this point:  it’s a singleton (i.e., InstanceContextMode = InstanceContextMode.Single in the ServiceBehavior attribute) and...