Skip to content

Instantly share code, notes, and snippets.

@bwatts

bwatts/gist:1a5d8947da6f07cd17e3

Created June 4, 2014 23:01
Show Gist options
  • Save bwatts/1a5d8947da6f07cd17e3 to your computer and use it in GitHub Desktop.
Save bwatts/1a5d8947da6f07cd17e3 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.cs
var consumer = new EventingBasicConsumer();
model.BasicConsume(_queueName, noAck: false, consumer: consumer);
var messages = Observable.FromEventPattern<BasicDeliverEventHandler, BasicDeliverEventArgs>(
handlerAdapter => consumer.Received += handlerAdapter,
handlerAdapter => consumer.Received -= handlerAdapter);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment