* Finish converting the use of string to QueueName and RoutingKey

lukebakken · lukebakken · commit 9cd825941868 · 2024-05-20T08:22:45.000-07:00
diff --git a/projects/RabbitMQ.Client/PublicAPI.Unshipped.txt b/projects/RabbitMQ.Client/PublicAPI.Unshipped.txt
@@ -988,6 +988,8 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
 ~static readonly RabbitMQ.Client.ConsumerTag.Empty -> RabbitMQ.Client.ConsumerTag
 ~static readonly RabbitMQ.Client.ExchangeName.AmqDirect -> RabbitMQ.Client.ExchangeName
 ~static readonly RabbitMQ.Client.ExchangeName.AmqFanout -> RabbitMQ.Client.ExchangeName
+~static readonly RabbitMQ.Client.ExchangeName.AmqHeaders -> RabbitMQ.Client.ExchangeName
+~static readonly RabbitMQ.Client.ExchangeName.AmqTopic -> RabbitMQ.Client.ExchangeName
 ~static readonly RabbitMQ.Client.ExchangeName.Empty -> RabbitMQ.Client.ExchangeName
 ~static readonly RabbitMQ.Client.ExchangeType.Direct -> RabbitMQ.Client.ExchangeType
 ~static readonly RabbitMQ.Client.ExchangeType.Fanout -> RabbitMQ.Client.ExchangeType
diff --git a/projects/RabbitMQ.Client/client/api/AmqpString.cs b/projects/RabbitMQ.Client/client/api/AmqpString.cs
@@ -233,6 +233,8 @@ public class ExchangeName : AmqpString
         public static readonly ExchangeName Empty = new ExchangeName();
         public static readonly ExchangeName AmqDirect = new ExchangeName("amq.direct");
         public static readonly ExchangeName AmqFanout = new ExchangeName("amq.fanout");
+        public static readonly ExchangeName AmqTopic = new ExchangeName("amq.topic");
+        public static readonly ExchangeName AmqHeaders = new ExchangeName("amq.headers");
 
         private ExchangeName() : base()
         {
diff --git a/projects/Test/Integration/TestAsyncConsumer.cs b/projects/Test/Integration/TestAsyncConsumer.cs
@@ -118,7 +118,7 @@ public async Task TestBasicRoundtripConcurrent()
                     return Task.CompletedTask;
                 };
 
-                await _channel.BasicConsumeAsync(q.QueueName, true, ConsumerTag.Empty, false, false, null, consumer);
+                await _channel.BasicConsumeAsync(qname, true, ConsumerTag.Empty, false, false, null, consumer);
 
                 // ensure we get a delivery
                 await AssertRanToCompletion(publish1SyncSource.Task, publish2SyncSource.Task);
diff --git a/projects/Test/Integration/TestConsumerCancelNotify.cs b/projects/Test/Integration/TestConsumerCancelNotify.cs
@@ -62,8 +62,8 @@ public Task TestConsumerCancelEvent()
         [Fact]
         public async Task TestCorrectConsumerTag()
         {
-            string q1 = GenerateQueueName();
-            string q2 = GenerateQueueName();
+            QueueName q1 = GenerateQueueName();
+            QueueName q2 = GenerateQueueName();
 
             await _channel.QueueDeclareAsync(q1, false, false, false);
             await _channel.QueueDeclareAsync(q2, false, false, false);
diff --git a/projects/Test/Integration/TestConsumerOperationDispatch.cs b/projects/Test/Integration/TestConsumerOperationDispatch.cs
@@ -114,9 +114,9 @@ public async Task TestDeliveryOrderingWithSingleChannel()
             for (int i = 0; i < Y; i++)
             {
                 IChannel ch = await _conn.CreateChannelAsync();
-                QueueDeclareOk q = await ch.QueueDeclareAsync("", durable: false, exclusive: true, autoDelete: true, arguments: null);
+                QueueDeclareOk q = await ch.QueueDeclareAsync(QueueName.Empty, durable: false, exclusive: true, autoDelete: true, arguments: null);
                 var qname = new QueueName(q.QueueName);
-                await ch.QueueBindAsync(queue: qname, exchange: _x, routingKey: "");
+                await ch.QueueBindAsync(queue: qname, exchange: _x, routingKey: RoutingKey.Empty);
                 _channels.Add(ch);
                 _queues.Add(q);
                 var cons = new CollectingConsumer(ch);
@@ -126,7 +126,7 @@ public async Task TestDeliveryOrderingWithSingleChannel()
 
             for (int i = 0; i < N; i++)
             {
-                await _channel.BasicPublishAsync(_x, "", _encoding.GetBytes("msg"));
+                await _channel.BasicPublishAsync(_x, RoutingKey.Empty, _encoding.GetBytes("msg"));
             }
 
             if (IntegrationFixture.IsRunningInCI)
@@ -163,9 +163,9 @@ public async Task TestChannelShutdownDoesNotShutDownDispatcher()
             IChannel ch1 = await _conn.CreateChannelAsync();
             IChannel ch2 = await _conn.CreateChannelAsync();
 
-            string q1 = (await ch1.QueueDeclareAsync()).QueueName;
-            string q2 = (await ch2.QueueDeclareAsync()).QueueName;
-            await ch2.QueueBindAsync(queue: q2, exchange: _x, routingKey: "");
+            QueueDeclareOk q1 = await ch1.QueueDeclareAsync();
+            QueueDeclareOk q2 = await ch2.QueueDeclareAsync();
+            await ch2.QueueBindAsync(queue: q2, exchange: _x, routingKey: RoutingKey.Empty);
 
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
             await ch1.BasicConsumeAsync(q1, true, new EventingBasicConsumer(ch1));
@@ -178,7 +178,7 @@ public async Task TestChannelShutdownDoesNotShutDownDispatcher()
             // closing this channel must not affect ch2
             await ch1.CloseAsync();
 
-            await ch2.BasicPublishAsync(_x, "", _encoding.GetBytes("msg"));
+            await ch2.BasicPublishAsync(_x, RoutingKey.Empty, _encoding.GetBytes("msg"));
             await WaitAsync(tcs, "received event");
         }
 
@@ -210,7 +210,7 @@ public override void HandleChannelShutdown(object channel, ShutdownEventArgs rea
         [Fact]
         public async Task TestChannelShutdownHandler()
         {
-            string q = await _channel.QueueDeclareAsync();
+            QueueDeclareOk q = await _channel.QueueDeclareAsync();
             var c = new ShutdownLatchConsumer();
 
             await _channel.BasicConsumeAsync(queue: q, autoAck: true, consumer: c);
diff --git a/projects/Test/Integration/TestEventingConsumer.cs b/projects/Test/Integration/TestEventingConsumer.cs
@@ -46,7 +46,7 @@ public TestEventingConsumer(ITestOutputHelper output) : base(output)
         [Fact]
         public async Task TestEventingConsumerRegistrationEvents()
         {
-            string q = await _channel.QueueDeclareAsync();
+            QueueDeclareOk q = await _channel.QueueDeclareAsync();
 
             var registeredTcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
             object registeredSender = null;
@@ -86,7 +86,8 @@ public async Task TestEventingConsumerRegistrationEvents()
         public async Task TestEventingConsumerDeliveryEvents()
         {
             var tcs0 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
-            string q = await _channel.QueueDeclareAsync();
+            QueueDeclareOk q = await _channel.QueueDeclareAsync();
+            QueueName qname = (QueueName)q;
 
             bool receivedInvoked = false;
             object receivedSender = null;
@@ -100,7 +101,7 @@ public async Task TestEventingConsumerDeliveryEvents()
             };
 
             await _channel.BasicConsumeAsync(q, true, ec);
-            await _channel.BasicPublishAsync(ExchangeName.Empty, q, _encoding.GetBytes("msg"));
+            await _channel.BasicPublishAsync(ExchangeName.Empty, (RoutingKey)qname, _encoding.GetBytes("msg"));
 
             await WaitAsync(tcs0, "received event");
             var tcs1 = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
diff --git a/projects/Test/Integration/TestExceptionMessages.cs b/projects/Test/Integration/TestExceptionMessages.cs
@@ -31,6 +31,7 @@
 
 using System;
 using System.Threading.Tasks;
+using RabbitMQ.Client;
 using RabbitMQ.Client.Exceptions;
 using Xunit;
 using Xunit.Abstractions;
@@ -46,7 +47,7 @@ public TestExceptionMessages(ITestOutputHelper output) : base(output)
         [Fact]
         public async Task TestAlreadyClosedExceptionMessage()
         {
-            string uuid = Guid.NewGuid().ToString();
+            QueueName uuid = new QueueName(Guid.NewGuid().ToString());
             try
             {
                 await _channel.QueueDeclarePassiveAsync(uuid);
diff --git a/projects/Test/Integration/TestExchangeDeclare.cs b/projects/Test/Integration/TestExchangeDeclare.cs
@@ -66,7 +66,8 @@ async Task f()
                         await Task.Delay(S_Random.Next(5, 50));
                         ExchangeName exchangeName = GenerateExchangeName();
                         await _channel.ExchangeDeclareAsync(exchange: exchangeName, type: ExchangeType.Fanout, false, false);
-                        await _channel.ExchangeBindAsync(destination: ex_destination, source: exchangeName, routingKey: "unused");
+                        await _channel.ExchangeBindAsync(destination: ex_destination, source: exchangeName,
+                            routingKey: new RoutingKey("unused"));
                         exchangeNames.Add(exchangeName);
                     }
                     catch (NotSupportedException e)
@@ -89,7 +90,7 @@ async Task f()
                     try
                     {
                         await Task.Delay(S_Random.Next(5, 50));
-                        await _channel.ExchangeUnbindAsync(destination: ex_destination, source: exchangeName, routingKey: "unused",
+                        await _channel.ExchangeUnbindAsync(destination: ex_destination, source: exchangeName, routingKey: (RoutingKey)"unused",
                             noWait: false, arguments: null);
                         await _channel.ExchangeDeleteAsync(exchange: exchangeName, ifUnused: false);
                     }
diff --git a/projects/Test/Integration/TestExtensions.cs b/projects/Test/Integration/TestExtensions.cs
@@ -49,7 +49,7 @@ public async Task TestConfirmBarrier()
             await _channel.ConfirmSelectAsync();
             for (int i = 0; i < 10; i++)
             {
-                await _channel.BasicPublishAsync(ExchangeName.Empty, string.Empty);
+                await _channel.BasicPublishAsync(ExchangeName.Empty, RoutingKey.Empty);
             }
             Assert.True(await _channel.WaitForConfirmsAsync());
         }
@@ -67,7 +67,7 @@ public async Task TestExchangeBinding()
 
             await _channel.ExchangeDeclareAsync((ExchangeName)"src", ExchangeType.Direct, false, false);
             await _channel.ExchangeDeclareAsync((ExchangeName)"dest", ExchangeType.Direct, false, false);
-            QueueName queue = await _channel.QueueDeclareAsync(string.Empty, false, false, true);
+            QueueName queue = await _channel.QueueDeclareAsync(QueueName.Empty, false, false, true);
 
             await _channel.ExchangeBindAsync((ExchangeName)"dest", (ExchangeName)"src", RoutingKey.Empty);
             await _channel.QueueBindAsync(queue, (ExchangeName)"dest", RoutingKey.Empty);
diff --git a/projects/Test/Integration/TestFloodPublishing.cs b/projects/Test/Integration/TestFloodPublishing.cs
@@ -156,9 +156,9 @@ public async Task TestMultithreadFloodPublishing()
                 });
             };
 
-            QueueDeclareOk q = await _channel.QueueDeclareAsync(queue: string.Empty,
+            QueueDeclareOk q = await _channel.QueueDeclareAsync(queue: QueueName.Empty,
                     passive: false, durable: false, exclusive: true, autoDelete: false, arguments: null);
-            string queueName = q.QueueName;
+            QueueName qname = (QueueName)q;
 
             Task pub = Task.Run(async () =>
             {
@@ -181,7 +181,7 @@ public async Task TestMultithreadFloodPublishing()
 
                     for (int i = 0; i < publishCount && false == stop; i++)
                     {
-                        await pubCh.BasicPublishAsync(ExchangeName.Empty, queueName, sendBody, true);
+                        await pubCh.BasicPublishAsync(ExchangeName.Empty, (RoutingKey)qname, sendBody, true);
                     }
 
                     await pubCh.WaitForConfirmsOrDieAsync();
@@ -222,8 +222,8 @@ public async Task TestMultithreadFloodPublishing()
                         await Task.Yield();
                     };
 
-                    await consumeCh.BasicConsumeAsync(queue: queueName, autoAck: true,
-                        consumerTag: string.Empty, noLocal: false, exclusive: false,
+                    await consumeCh.BasicConsumeAsync(queue: qname, autoAck: true,
+                        consumerTag: ConsumerTag.Empty, noLocal: false, exclusive: false,
                         arguments: null, consumer: consumer);
 
                     Assert.True(await tcs.Task);
diff --git a/projects/Test/Integration/TestMainLoop.cs b/projects/Test/Integration/TestMainLoop.cs
@@ -72,7 +72,7 @@ public override Task HandleBasicDeliverAsync(ConsumerTag consumerTag,
         public async Task TestCloseWithFaultyConsumer()
         {
             var tcs = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
-            QueueDeclareOk q = await _channel.QueueDeclareAsync(string.Empty, false, false, false);
+            QueueDeclareOk q = await _channel.QueueDeclareAsync(QueueName.Empty, false, false, false);
             var rk = new RoutingKey(q.QueueName);
 
             CallbackExceptionEventArgs ea = null;
diff --git a/projects/Test/Integration/TestMessageCount.cs b/projects/Test/Integration/TestMessageCount.cs
@@ -46,11 +46,11 @@ public TestMessageCount(ITestOutputHelper output) : base(output)
         public async Task TestMessageCountMethod()
         {
             await _channel.ConfirmSelectAsync();
-            string q = GenerateQueueName();
+            QueueName q = GenerateQueueName();
             await _channel.QueueDeclareAsync(queue: q, passive: false, durable: false, exclusive: true, autoDelete: false, arguments: null);
             Assert.Equal(0u, await _channel.MessageCountAsync(q));
 
-            await _channel.BasicPublishAsync(ExchangeName.Empty, q, _encoding.GetBytes("msg"));
+            await _channel.BasicPublishAsync(ExchangeName.Empty, (RoutingKey)q, _encoding.GetBytes("msg"));
             await _channel.WaitForConfirmsAsync();
             Assert.Equal(1u, await _channel.MessageCountAsync(q));
         }
diff --git a/projects/Test/Integration/TestNowait.cs b/projects/Test/Integration/TestNowait.cs
@@ -47,7 +47,7 @@ public TestNoWait(ITestOutputHelper output) : base(output)
         [Fact]
         public async Task TestQueueDeclareNoWait()
         {
-            string q = GenerateQueueName();
+            QueueName q = GenerateQueueName();
             await _channel.QueueDeclareAsync(q, false, true, false, noWait: true, arguments: null);
             await _channel.QueueDeclarePassiveAsync(q);
         }
@@ -57,7 +57,7 @@ public Task TestQueueDeclareServerNamedNoWait()
         {
             return Assert.ThrowsAsync<InvalidOperationException>(() =>
             {
-                return _channel.QueueDeclareAsync("", false, true, false, noWait: true);
+                return _channel.QueueDeclareAsync(QueueName.Empty, false, true, false, noWait: true);
             });
         }
 
@@ -66,13 +66,13 @@ public async Task TestQueueBindNoWait()
         {
             QueueName q = GenerateQueueName();
             await _channel.QueueDeclareAsync(q, false, true, false, noWait: true);
-            await _channel.QueueBindAsync(q, (ExchangeName)(ExchangeName)"amq.fanout", "", noWait: true);
+            await _channel.QueueBindAsync(q, ExchangeName.AmqFanout, RoutingKey.Empty, noWait: true);
         }
 
         [Fact]
         public async Task TestQueueDeleteNoWait()
         {
-            string q = GenerateQueueName();
+            QueueName q = GenerateQueueName();
             await _channel.QueueDeclareAsync(q, false, true, false, noWait: true);
             await _channel.QueueDeleteAsync(q, false, false, noWait: true);
             await Assert.ThrowsAsync<OperationInterruptedException>(() =>
@@ -103,7 +103,7 @@ public async Task TestExchangeBindNoWait()
             try
             {
                 await _channel.ExchangeDeclareAsync(x, ExchangeType.Fanout, false, true, noWait: true);
-                await _channel.ExchangeBindAsync(x, (ExchangeName)"amq.fanout", "", noWait: true);
+                await _channel.ExchangeBindAsync(x, ExchangeName.AmqFanout, RoutingKey.Empty, noWait: true);
             }
             finally
             {
@@ -118,8 +118,8 @@ public async Task TestExchangeUnbindNoWait()
             try
             {
                 await _channel.ExchangeDeclareAsync(x, ExchangeType.Fanout, false, true);
-                await _channel.ExchangeBindAsync(x, (ExchangeName)"amq.fanout", "", noWait: true);
-                await _channel.ExchangeUnbindAsync(x, (ExchangeName)"amq.fanout", "", noWait: true);
+                await _channel.ExchangeBindAsync(x, ExchangeName.AmqFanout, RoutingKey.Empty, noWait: true);
+                await _channel.ExchangeUnbindAsync(x, ExchangeName.AmqFanout, RoutingKey.Empty, noWait: true);
             }
             finally
             {
diff --git a/projects/Test/Integration/TestPublishSharedChannelAsync.cs b/projects/Test/Integration/TestPublishSharedChannelAsync.cs
@@ -39,7 +39,7 @@ namespace Test.Integration
 {
     public class TestPublishSharedChannelAsync : IntegrationFixture
     {
-        private const string QueueName = "TestPublishSharedChannel_Queue";
+        private static readonly QueueName s_queueName = new QueueName("TestPublishSharedChannel_Queue");
         private static readonly ExchangeName s_exchangeName = new ExchangeName("TestPublishSharedChannel_Ex");
         private static readonly RoutingKey s_publishKey = new RoutingKey("TestPublishSharedChannel_RoutePub");
         private const int Loops = 20;
@@ -70,7 +70,7 @@ public override Task DisposeAsync()
         [Fact]
         public async Task MultiThreadPublishOnSharedChannel()
         {
-            var cf = CreateConnectionFactory();
+            ConnectionFactory cf = CreateConnectionFactory();
             cf.AutomaticRecoveryEnabled = false;
 
             using (IConnection conn = await cf.CreateConnectionAsync())
@@ -87,8 +87,8 @@ public async Task MultiThreadPublishOnSharedChannel()
                             channel.ChannelShutdown += HandleChannelShutdown;
                             await channel.ExchangeDeclareAsync(s_exchangeName, ExchangeType.Topic, passive: false, durable: false, autoDelete: true,
                                 noWait: false, arguments: null);
-                            await channel.QueueDeclareAsync(QueueName, exclusive: false, autoDelete: true);
-                            await channel.QueueBindAsync(QueueName, s_exchangeName, s_publishKey);
+                            await channel.QueueDeclareAsync(s_queueName, exclusive: false, autoDelete: true);
+                            await channel.QueueBindAsync(s_queueName, s_exchangeName, s_publishKey);
 
                             for (int i = 0; i < Loops; i++)
                             {
diff --git a/projects/Test/Integration/TestPublisherConfirms.cs b/projects/Test/Integration/TestPublisherConfirms.cs
@@ -121,7 +121,7 @@ public Task TestWaitForConfirmsWithTimeoutAsync_MessageNacked_WaitingHasTimedout
         [Fact]
         public async Task TestWaitForConfirmsWithEventsAsync()
         {
-            string queueName = string.Format("{0}:{1}", _testDisplayName, Guid.NewGuid());
+            QueueName queueName = GenerateQueueName();
             using (IChannel ch = await _conn.CreateChannelAsync())
             {
                 await ch.ConfirmSelectAsync();
@@ -140,7 +140,7 @@ public async Task TestWaitForConfirmsWithEventsAsync()
                 {
                     for (int i = 0; i < n; i++)
                     {
-                        await ch.BasicPublishAsync(ExchangeName.Empty, queueName, _encoding.GetBytes("msg"));
+                        await ch.BasicPublishAsync(ExchangeName.Empty, (RoutingKey)queueName, _encoding.GetBytes("msg"));
                     }
 
                     await ch.WaitForConfirmsAsync();
diff --git a/projects/Test/Integration/TestQueueDeclare.cs b/projects/Test/Integration/TestQueueDeclare.cs
diff --git a/projects/Test/Integration/TestToxiproxy.cs b/projects/Test/Integration/TestToxiproxy.cs
diff --git a/projects/Test/OAuth2/TestOAuth2.cs b/projects/Test/OAuth2/TestOAuth2.cs
diff --git a/projects/Test/SequentialIntegration/SequentialIntegrationFixture.cs b/projects/Test/SequentialIntegration/SequentialIntegrationFixture.cs
diff --git a/projects/Test/SequentialIntegration/TestActivitySource.cs b/projects/Test/SequentialIntegration/TestActivitySource.cs
diff --git a/projects/Test/SequentialIntegration/TestConnectionRecovery.cs b/projects/Test/SequentialIntegration/TestConnectionRecovery.cs

Original file line number	Diff line number	Diff line change
`@@ -233,6 +233,8 @@ public class ExchangeName : AmqpString`
`233`	`233`	`public static readonly ExchangeName Empty = new ExchangeName();`
`234`	`234`	`public static readonly ExchangeName AmqDirect = new ExchangeName("amq.direct");`
`235`	`235`	`public static readonly ExchangeName AmqFanout = new ExchangeName("amq.fanout");`
	`236`	`+ public static readonly ExchangeName AmqTopic = new ExchangeName("amq.topic");`
	`237`	`+ public static readonly ExchangeName AmqHeaders = new ExchangeName("amq.headers");`
`236`	`238`
`237`	`239`	`private ExchangeName() : base()`
`238`	`240`	`{`
Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,8 @@ async Task f()`
`66`	`66`	`await Task.Delay(S_Random.Next(5, 50));`
`67`	`67`	`ExchangeName exchangeName = GenerateExchangeName();`
`68`	`68`	`await _channel.ExchangeDeclareAsync(exchange: exchangeName, type: ExchangeType.Fanout, false, false);`
`69`		`- await _channel.ExchangeBindAsync(destination: ex_destination, source: exchangeName, routingKey: "unused");`
	`69`	`+ await _channel.ExchangeBindAsync(destination: ex_destination, source: exchangeName,`
	`70`	`+ routingKey: new RoutingKey("unused"));`
`70`	`71`	`exchangeNames.Add(exchangeName);`
`71`	`72`	`}`
`72`	`73`	`catch (NotSupportedException e)`
`@@ -89,7 +90,7 @@ async Task f()`
`89`	`90`	`try`
`90`	`91`	`{`
`91`	`92`	`await Task.Delay(S_Random.Next(5, 50));`
`92`		`- await _channel.ExchangeUnbindAsync(destination: ex_destination, source: exchangeName, routingKey: "unused",`
	`93`	`+ await _channel.ExchangeUnbindAsync(destination: ex_destination, source: exchangeName, routingKey: (RoutingKey)"unused",`
`93`	`94`	`noWait: false, arguments: null);`
`94`	`95`	`await _channel.ExchangeDeleteAsync(exchange: exchangeName, ifUnused: false);`
`95`	`96`	`}`
Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ public async Task TestConfirmBarrier()`
`49`	`49`	`await _channel.ConfirmSelectAsync();`
`50`	`50`	`for (int i = 0; i < 10; i++)`
`51`	`51`	`{`
`52`		`- await _channel.BasicPublishAsync(ExchangeName.Empty, string.Empty);`
	`52`	`+ await _channel.BasicPublishAsync(ExchangeName.Empty, RoutingKey.Empty);`
`53`	`53`	`}`
`54`	`54`	`Assert.True(await _channel.WaitForConfirmsAsync());`
`55`	`55`	`}`
`@@ -67,7 +67,7 @@ public async Task TestExchangeBinding()`
`67`	`67`
`68`	`68`	`await _channel.ExchangeDeclareAsync((ExchangeName)"src", ExchangeType.Direct, false, false);`
`69`	`69`	`await _channel.ExchangeDeclareAsync((ExchangeName)"dest", ExchangeType.Direct, false, false);`
`70`		`- QueueName queue = await _channel.QueueDeclareAsync(string.Empty, false, false, true);`
	`70`	`+ QueueName queue = await _channel.QueueDeclareAsync(QueueName.Empty, false, false, true);`
`71`	`71`
`72`	`72`	`await _channel.ExchangeBindAsync((ExchangeName)"dest", (ExchangeName)"src", RoutingKey.Empty);`
`73`	`73`	`await _channel.QueueBindAsync(queue, (ExchangeName)"dest", RoutingKey.Empty);`