Plumbed Channel Creation Mode into the Factories BrighterCommand#1444

preardon · Mar 27, 2021 · f049d11 · f049d11
1 parent 965491b
commit f049d11
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumerFactory.cs b/src/Paramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusConsumerFactory.cs
@@ -18,8 +18,10 @@ public IAmAMessageConsumer Create(Subscription subscription)
 
             return new AzureServiceBusConsumer(subscription.RoutingKey, subscription.ChannelName,
                 new AzureServiceBusMessageProducer(nameSpaceManagerWrapper,
-                    new TopicClientProvider(_configuration)), nameSpaceManagerWrapper,
-                new MessageReceiverProvider(_configuration), receiveMode: _configuration.AckOnRead ? ReceiveMode.PeekLock : ReceiveMode.ReceiveAndDelete);
+                    new TopicClientProvider(_configuration), subscription.MakeChannels), nameSpaceManagerWrapper,
+                new MessageReceiverProvider(_configuration),
+                makeChannels: subscription.MakeChannels,
+                receiveMode: _configuration.AckOnRead ? ReceiveMode.PeekLock : ReceiveMode.ReceiveAndDelete);
         }
     }
 }
diff --git a/...ramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusMessageProducerFactory.cs b/...ramore.Brighter.MessagingGateway.AzureServiceBus/AzureServiceBusMessageProducerFactory.cs
@@ -4,12 +4,12 @@ namespace Paramore.Brighter.MessagingGateway.AzureServiceBus
 {
     public static class AzureServiceBusMessageProducerFactory
     {
-        public static AzureServiceBusMessageProducer Get(AzureServiceBusConfiguration configuration)
+        public static AzureServiceBusMessageProducer Get(AzureServiceBusConfiguration configuration, OnMissingChannel makeChannel = OnMissingChannel.Create)
         {
             var nameSpaceManagerWrapper = new ManagementClientWrapper(configuration);
             var topicClientProvider = new TopicClientProvider(configuration);
 
-            return new AzureServiceBusMessageProducer(nameSpaceManagerWrapper, topicClientProvider);
+            return new AzureServiceBusMessageProducer(nameSpaceManagerWrapper, topicClientProvider, makeChannel);
         }
     }
 }