Guest User

Untitled

a guest
Mar 18th, 2018
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.57 KB | None | 0 0
  1. var factory = MessagingFactory.CreateFromConnectionString("blah");
  2. sender = factory.CreateMessageSender("MyTopicName");
  3.  
  4. var tasks = new List<Task>();
  5. for (int i = 0; i < 10; i++)
  6. tasks.Add(sender.SendAsync(new BrokeredMessage("My Message")));
  7.  
  8. await Task.WhenAll(tasks); // This completes within a few millis
  9.  
  10. receiver = factory.CreateSubscriptionClient("MyTopicName", "MySubscription");
  11. _sbClient.OnMessageAsync(async message =>
  12. {
  13. var msg = message.GetBody<string>();
  14. // log time-taken: 200+ms gap between log statements
  15. await message.CompleteAsync();
  16. });
Add Comment
Please, Sign In to add comment