using validating model in all places

Author: tmasternak

src/NServiceBus.Transport.RabbitMQ/Administration/QueueCreator.cs

@@ -16,7 +16,7 @@ public QueueCreator(ConnectionFactory connectionFactory, IRoutingTopology routin
         public Task CreateQueueIfNecessary(QueueBindings queueBindings, string identity)
         {
             using (var connection = connectionFactory.CreateAdministrationConnection())
-            using (var channel = connection.CreateModel())
+            using (var channel = new ModelWithValidation(connection.CreateModel()))
             {
                 DelayInfrastructure.Build(channel);
 

src/NServiceBus.Transport.RabbitMQ/Administration/QueuePurger.cs

@@ -12,7 +12,7 @@ public QueuePurger(ConnectionFactory connectionFactory)
         public void Purge(string queue)
         {
             using (var connection = connectionFactory.CreateAdministrationConnection())
-            using (var channel = connection.CreateModel())
+            using (var channel = new ModelWithValidation(connection.CreateModel()))
             {
                 channel.QueuePurge(queue);
             }

src/NServiceBus.Transport.RabbitMQ/Administration/SubscriptionManager.cs

@@ -20,7 +20,7 @@ public SubscriptionManager(ConnectionFactory connectionFactory, IRoutingTopology
         public Task Subscribe(Type eventType, ContextBag context)
         {
             using (var connection = connectionFactory.CreateAdministrationConnection())
-            using (var channel = connection.CreateModel())
+            using (var channel = new ModelWithValidation(connection.CreateModel()))
             {
                 routingTopology.SetupSubscription(channel, eventType, localQueue);
             }
@@ -31,7 +31,7 @@ public Task Subscribe(Type eventType, ContextBag context)
         public Task Unsubscribe(Type eventType, ContextBag context)
         {
             using (var connection = connectionFactory.CreateAdministrationConnection())
-            using (var channel = connection.CreateModel())
+            using (var channel = new ModelWithValidation(connection.CreateModel()))
             {
                 routingTopology.TeardownSubscription(channel, eventType, localQueue);
             }

src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs

@@ -81,7 +81,7 @@ public void Start(PushRuntimeSettings limitations)
 
             connection = connectionFactory.CreateConnection($"{settings.InputQueue} MessagePump");
 
-            var channel = connection.CreateModel();
+            var channel = new ModelWithValidation(connection.CreateModel());
 
             long prefetchCount;