Reactive extensions for EasyNetQ