Declarative syntax for piping data in Azure Service Bus Message queues and other technologies.
Simply add the FluentMessaging NuGet package to your project.
QueueFramework
.FromQueue(queueConnectionString, queueName)
.ProcessWith<PassthroughQueueProcessor>()
.OutputToTopic(topicConnectionString, queueName);
var rx = QueueFramework
.FromTopicSubscription(connectionString, topicName, subscriptionName)
.OutputToReactive(serializer);
Microsoft Developer & Platform Evangelism
Copyright (c) Microsoft Corporation. All rights reserved.
THIS CODE AND INFORMATION ARE PROVIDED "AS IS" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE IMPLIED WARRANTIES OF MERCHANTABILITY AND/OR FITNESS FOR A PARTICULAR PURPOSE.
The example companies, organizations, products, domain names, e-mail addresses, logos, people, places, and events depicted herein are fictitious. No association with any real company, organization, product, domain name, email address, logo, person, places, or events is intended or should be inferred.