snippetize the native pub sub article

Particular · Mar 17, 2021 · 4b9116b · 4b9116b
1 parent ab7c785
commit 4b9116b
Show file tree

Hide file tree

Showing 3 changed files with 43 additions and 16 deletions.
diff --git a/Snippets/ASQ/ASQN_10/Usage.cs b/Snippets/ASQ/ASQN_10/Usage.cs
@@ -97,11 +97,27 @@ void RegisterPublisher(EndpointConfiguration configuration)
         #region storage_account_routing_registered_publisher
 
         var transportConfig = configuration.UseTransport<AzureStorageQueueTransport>();
+        transportConfig.DefaultAccountAlias("subscriber");
+        var routing = transportConfig
+                            .ConnectionString("connectionString")
+                            .AccountRouting();
+        var anotherAccount = routing.AddAccount("publisher", "anotherConnectionString");
+        anotherAccount.AddEndpoint("Publisher1", new[] { typeof(MyEvent) }, "optionalSubscriptionTableName");
+
+        #endregion
+    }
+
+    void RegisterSubscriber(EndpointConfiguration configuration)
+    {
+        #region storage_account_routing_registered_subscriber
+
+        var transportConfig = configuration.UseTransport<AzureStorageQueueTransport>();
+        transportConfig.DefaultAccountAlias("publisher");
         var routing = transportConfig
                             .ConnectionString("anotherConnectionString")
                             .AccountRouting();
-        var anotherAccount = routing.AddAccount("PublisherAccountName", "connectionString");
-        anotherAccount.AddEndpoint("Publisher", new[] { typeof(MyEvent) });
+        var anotherAccount = routing.AddAccount("subscriber", "connectionString");
+        anotherAccount.AddEndpoint("Subscriber1");
 
         #endregion
     }

diff --git a/Snippets/ASQ/ASQN_11/Usage.cs b/Snippets/ASQ/ASQN_11/Usage.cs
@@ -99,8 +99,29 @@ void RegisterPublisher(EndpointConfiguration configuration)
         #region storage_account_routing_registered_publisher
 
         var transport = new AzureStorageQueueTransport("connectionString");
-        var anotherAccount = transport.AccountRouting.AddAccount("PublisherAccountName", "anotherConnectionString");
-        anotherAccount.AddEndpoint("Publisher", new[] { typeof(MyEvent)  });
+
+        transport.AccountRouting.DefaultAccountAlias = "subscriber";
+
+        var anotherAccount = transport.AccountRouting.AddAccount("publisher", "anotherConnectionString");
+        anotherAccount.AddEndpoint("Publisher1", new[] { typeof(MyEvent)  }, "optionalSubscriptionTableName");
+
+        configuration.UseTransport(transport);
+
+        #endregion
+#pragma warning restore CS0618
+    }
+
+    void RegisterSubscriber(EndpointConfiguration configuration)
+    {
+#pragma warning disable CS0618
+        #region storage_account_routing_registered_subscriber
+
+        var transport = new AzureStorageQueueTransport("anotherConnectionString");
+
+        transport.AccountRouting.DefaultAccountAlias = "publisher";
+
+        var anotherAccount = transport.AccountRouting.AddAccount("subscriber", "connectionString");
+        anotherAccount.AddEndpoint("Subscriber1");
 
         configuration.UseTransport(transport);
 

diff --git a/transports/azure-storage-queues/native-publish-subscribe.md b/transports/azure-storage-queues/native-publish-subscribe.md
@@ -35,18 +35,8 @@ When the publisher dispatches the unicast operations, it queries for the interes
 
 The following endpoint configuration is required to make sure `Subscriber1` can subscribe to `OrderAccepted` and `Publisher1` can send the message. The publisher configuration
 
-```csharp
-transport.AccountRouting.DefaultAccountAlias = "publisher";
-
-var anotherAccount = transport.AccountRouting.AddAccount("subscriber", ...);
-anotherAccount.AddEndpoint("Subscriber1");
-```
+snippet: storage_account_routing_registered_subscriber
 
 the subscriber configuration
 
-```csharp
-transport.AccountRouting.DefaultAccountAlias = "subscriber";
-
-var anotherAccount = transport.AccountRouting.AddAccount("publisher", ...);
-anotherAccount.AddEndpoint("Publisher1", new[] { typeof(OrderAccepted) }, "optionalSubscriptionTableName");
-```
+snippet: storage_account_routing_registered_publisher