Fix RabbitMQ connection issue

- ampq should be amqp

Author: TimHess

src/Messaging/src/RabbitMQ/Extensions/RabbitServicesExtensions.cs

@@ -1,4 +1,4 @@
-// Licensed to the .NET Foundation under one or more agreements.
+// Licensed to the .NET Foundation under one or more agreements.
 // The .NET Foundation licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information.
 
@@ -251,8 +251,8 @@ public static IServiceCollection ConfigureRabbitOptions(this IServiceCollection
                     if (connectionFactory is not null)
                     {
                         var scheme = connectionFactory.Ssl.Enabled
-                            ? "ampqs://"
-                            : "ampq://";
+                            ? "amqps://"
+                            : "amqp://";
 
                         options.Addresses = $"{scheme}{connectionFactory.UserName}:{connectionFactory.Password}@{connectionFactory.HostName}:{connectionFactory.Port}";
                         options.VirtualHost = connectionFactory.VirtualHost;

src/Messaging/test/RabbitMQ.Test/Extensions/RabbitServiceExtensionsTest.cs

@@ -540,7 +540,7 @@ public void ConfigureRabbitOptions_OverrideAddressWithServiceInfo()
         Assert.Equal("Dd6O1BPXUHdrmzbP", rabbitOptions.Username);
         Assert.Equal("7E1LxXnlH2hhlPVt", rabbitOptions.Password);
         Assert.Equal("cf_b4f8d2fa_a3ea_4e3a_a0e8_2cd040790355", rabbitOptions.VirtualHost);
-        Assert.Equal("ampq://Dd6O1BPXUHdrmzbP:[email protected]:3306", rabbitOptions.Addresses);
+        Assert.Equal("amqp://Dd6O1BPXUHdrmzbP:[email protected]:3306", rabbitOptions.Addresses);
     }
 
     [Fact]

src/Stream/test/StreamBase.Test/StreamsHost/StreamsHostTest.cs

@@ -62,7 +62,7 @@ public void HostConfiguresRabbitOptions()
             Assert.Equal("Dd6O1BPXUHdrmzbP", rabbitOptions.Username);
             Assert.Equal("7E1LxXnlH2hhlPVt", rabbitOptions.Password);
             Assert.Equal("cf_b4f8d2fa_a3ea_4e3a_a0e8_2cd040790355", rabbitOptions.VirtualHost);
-            Assert.Equal("ampq://Dd6O1BPXUHdrmzbP:[email protected]:3306", rabbitOptions.Addresses);
+            Assert.Equal("amqp://Dd6O1BPXUHdrmzbP:[email protected]:3306", rabbitOptions.Addresses);
         }
     }