Skip to content

Instantly share code, notes, and snippets.

@rseroter
Created August 22, 2012 21:14
Show Gist options
  • Save rseroter/3429452 to your computer and use it in GitHub Desktop.
Save rseroter/3429452 to your computer and use it in GitHub Desktop.
Example code #2 for using Iron Foundry application service (Microsoft Service Bus)
public static void SendMessage(string message)
{
var msg = new BrokeredMessage(message);
MessagingFactory factory = Nested.instance.messagingFactory;
MessageSender msgSender = factory.CreateMessageSender(QueueName);
msgSender.Send(msg);
}
public static IEnumerable<string> ReceiveMessages(ushort messageCount)
{
IEnumerable<string> rv = null;
MessageReceiver msgReceiver = Nested.instance.messagingFactory.CreateMessageReceiver(QueueName);
IEnumerable<BrokeredMessage> msgs = msgReceiver.ReceiveBatch(messageCount, TimeSpan.FromSeconds(2));
if (msgs != null)
{
rv = msgs.Select(m =>
{
string msg = m.GetBody<string>();
m.Complete();
return msg;
});
}
return rv;
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment