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...
Bnaya has released a new version of the RxContrib project which includes the Reactive Queue – an RX interface above a message queue. This version has a provider for CCR ports as the underlying queue mechanism. This provider supports a Port<T> for OnNext notifications, and PortSet<T, Exception> for both OnNext and OnError notifications. To compile, make sure that you have a version of the CCR available (you can download it from here ) and change the appropriate references...