Created
March 6, 2016 12:47
-
-
Save BenjaminAbt/03349508bab653d7ab39 to your computer and use it in GitHub Desktop.
Azure Service Bus Queue Demo Service
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// 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