diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysCreateCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysCreateCommand.cs
index 64f65b4f3..b1133a6d8 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysCreateCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysCreateCommand.cs
@@ -15,7 +15,7 @@ public static Command CreateCommand()
{
var brokerConnection = brokerConnectionBinder.CreateBrokerConnection(parseResult);
- var delaysCreate = new DelaysCreateCommand(brokerConnection, parseResult.Configuration.Output);
+ var delaysCreate = new DelaysCreateCommand(brokerConnection, parseResult.InvocationConfiguration.Output);
await delaysCreate.Run(cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysMigrateCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysMigrateCommand.cs
index 757ba4ae1..779204f9b 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysMigrateCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysMigrateCommand.cs
@@ -35,7 +35,7 @@ public static Command CreateCommand()
_ => throw new InvalidOperationException()
};
- var delaysMigrate = new DelaysMigrateCommand(brokerConnection, routingTopology, parseResult.Configuration.Output);
+ var delaysMigrate = new DelaysMigrateCommand(brokerConnection, routingTopology, parseResult.InvocationConfiguration.Output);
await delaysMigrate.Run(cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysVerifyCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysVerifyCommand.cs
index 4eee2d558..dbe8e6720 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysVerifyCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Delays/DelaysVerifyCommand.cs
@@ -15,7 +15,7 @@ public static Command CreateCommand()
{
var brokerVerifier = brokerVerifierBinder.CreateBrokerVerifier(parseResult);
- var delaysVerify = new DelaysVerifyCommand(brokerVerifier, parseResult.Configuration.Output);
+ var delaysVerify = new DelaysVerifyCommand(brokerVerifier, parseResult.InvocationConfiguration.Output);
await delaysVerify.Run(cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Endpoint/EndpointCreateCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Endpoint/EndpointCreateCommand.cs
index 020aa87fd..7da89d971 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Endpoint/EndpointCreateCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Endpoint/EndpointCreateCommand.cs
@@ -44,7 +44,7 @@ public static Command CreateCommand()
var brokerConnection = brokerConnectionBinder.CreateBrokerConnection(parseResult);
var routingTopology = routingTopologyBinder.CreateRoutingTopology(parseResult);
- var queueCreate = new EndpointCreateCommand(brokerConnection, routingTopology, parseResult.Configuration.Output, parseResult.Configuration.Error);
+ var queueCreate = new EndpointCreateCommand(brokerConnection, routingTopology, parseResult.InvocationConfiguration.Output, parseResult.InvocationConfiguration.Error);
await queueCreate.Run(parseResult.GetRequiredValue(endpointNameArgument), parseResult.GetValue(errorQueueOption), parseResult.GetValue(auditQueueOption), parseResult.GetValue(instanceDiscriminatorsOption), cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueMigrateCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueMigrateCommand.cs
index 4baadb1fa..b41f05091 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueMigrateCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueMigrateCommand.cs
@@ -25,7 +25,7 @@ public static Command CreateCommand()
{
var brokerConnection = brokerConnectionBinder.CreateBrokerConnection(parseResult);
- var migrateCommand = new QueueMigrateCommand(parseResult.GetRequiredValue(queueNameArgument), brokerConnection, parseResult.Configuration.Output);
+ var migrateCommand = new QueueMigrateCommand(parseResult.GetRequiredValue(queueNameArgument), brokerConnection, parseResult.InvocationConfiguration.Output);
await migrateCommand.Run(cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueValidateDeliveryLimitCommand.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueValidateDeliveryLimitCommand.cs
index bb9bcb46c..25b8b3cba 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueValidateDeliveryLimitCommand.cs
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/Commands/Queue/QueueValidateDeliveryLimitCommand.cs
@@ -21,7 +21,7 @@ public static Command CreateCommand()
{
var brokerVerifier = brokerVerifierBinder.CreateBrokerVerifier(parseResult);
- var validateCommand = new QueueValidateDeliveryLimitCommand(parseResult.GetRequiredValue(queueNameArgument), brokerVerifier, parseResult.Configuration.Output);
+ var validateCommand = new QueueValidateDeliveryLimitCommand(parseResult.GetRequiredValue(queueNameArgument), brokerVerifier, parseResult.InvocationConfiguration.Output);
await validateCommand.Run(cancellationToken);
});
diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine/NServiceBus.Transport.RabbitMQ.CommandLine.csproj b/src/NServiceBus.Transport.RabbitMQ.CommandLine/NServiceBus.Transport.RabbitMQ.CommandLine.csproj
index 798d13c1a..cdce7b26e 100644
--- a/src/NServiceBus.Transport.RabbitMQ.CommandLine/NServiceBus.Transport.RabbitMQ.CommandLine.csproj
+++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine/NServiceBus.Transport.RabbitMQ.CommandLine.csproj
@@ -19,7 +19,7 @@
-
+