Skip to content

Instantly share code, notes, and snippets.

@BenjaminAbt
Created March 6, 2016 12:47
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save BenjaminAbt/03349508bab653d7ab39 to your computer and use it in GitHub Desktop.
Save BenjaminAbt/03349508bab653d7ab39 to your computer and use it in GitHub Desktop.
Azure Service Bus Queue Demo Service
// QueueClient des NuGet Pakets WindowsAzure.ServiceBus
_queueClient = QueueClient.CreateFromConnectionString( connectionString, queueName );
// Senden von Nachrichten
// Es empfiehlt sich hier die Serialisierung der Daten, bei Strings zb. als Json
_queueClient.Send( new BrokeredMessage( JsonConvert.SerializeObject( payload ) ) );
// Nachrichten werden über Callbacks empfangen
// Der Einfachheit halber biete ich den QueueService Empfängern die Informationen als Event an
// Niemand muss dabei periodische die Queue anfragen, ob es neue Nachrichten gibt
// Hierbei weiß ich, dass die Daten nur strings sind und im Json Format kommen
_queueClient.OnMessage( HandleOnQueueMessage );
private void HandleOnQueueMessage( BrokeredMessage brokeredMessage )
{
// Get the origin json payload
string jsonPayload = brokeredMessage.GetBody<string>();
// convert to string
string message = JsonConvert.DeserializeObject<string>( jsonPayload );
OnNewMessage?.Invoke( this, message );
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment