* Add SaslMechanism.Anonymous

Author: lukebakken

RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

@@ -264,7 +264,11 @@ [new Symbol("connection_name")] = _connectionSettings.ContainerId,
                     }
                 }
 
-                if (_connectionSettings.SaslMechanism == SaslMechanism.External)
+                if (_connectionSettings.SaslMechanism == SaslMechanism.Anonymous)
+                {
+                    cf.SASL.Profile = SaslProfile.Anonymous;
+                }
+                else if (_connectionSettings.SaslMechanism == SaslMechanism.External)
                 {
                     cf.SASL.Profile = SaslProfile.External;
                 }

RabbitMQ.AMQP.Client/Impl/ConnectionSettings.cs

@@ -89,7 +89,8 @@ public ConnectionSettingBuilder MaxFrameSize(uint maxFrameSize)
         public ConnectionSettingBuilder SaslMechanism(SaslMechanism saslMechanism)
         {
             _saslMechanism = saslMechanism;
-            if (_saslMechanism == Client.SaslMechanism.External)
+            if (_saslMechanism == Client.SaslMechanism.Anonymous ||
+                _saslMechanism == Client.SaslMechanism.External)
             {
                 _user = null;
                 _password = null;

RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt

@@ -541,6 +541,7 @@ static RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.Create() -> RabbitMQ.AMQP.Cl
 static RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.Create(int maxAttempt) -> RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy!
 static RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder.Create() -> RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder!
 static RabbitMQ.AMQP.Client.Impl.RecoveryConfiguration.Create() -> RabbitMQ.AMQP.Client.Impl.RecoveryConfiguration!
+static readonly RabbitMQ.AMQP.Client.SaslMechanism.Anonymous -> RabbitMQ.AMQP.Client.SaslMechanism!
 static readonly RabbitMQ.AMQP.Client.SaslMechanism.External -> RabbitMQ.AMQP.Client.SaslMechanism!
 static readonly RabbitMQ.AMQP.Client.SaslMechanism.Plain -> RabbitMQ.AMQP.Client.SaslMechanism!
 virtual RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.Dispose(bool disposing) -> void

RabbitMQ.AMQP.Client/SaslMechanism.cs

@@ -10,6 +10,7 @@ public class SaslMechanism : IEquatable<SaslMechanism>
     {
         public static readonly SaslMechanism Plain = new("PLAIN");
         public static readonly SaslMechanism External = new("EXTERNAL");
+        public static readonly SaslMechanism Anonymous = new("ANONYMOUS");
 
         private readonly string _saslMechanism;
 

Tests/ConnectionTests/AnonymousConnectionTests.cs

@@ -0,0 +1,33 @@
+// This source code is dual-licensed under the Apache License, version
+// 2.0, and the Mozilla Public License, version 2.0.
+// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
+
+using System.Threading.Tasks;
+using RabbitMQ.AMQP.Client;
+using RabbitMQ.AMQP.Client.Impl;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Tests.ConnectionTests;
+
+public class AnonymousConnectionTests(ITestOutputHelper testOutputHelper)
+    : IntegrationTest(testOutputHelper, setupConnectionAndManagement: false)
+{
+    [Fact]
+    public async Task ConnectUsingSaslAnonynmous()
+    {
+        Assert.Null(_connection);
+        Assert.Null(_management);
+
+        ConnectionSettingBuilder connectionSettingBuilder = ConnectionSettingBuilder.Create();
+
+        _containerId = $"{_testDisplayName}:{Now}";
+        connectionSettingBuilder.ContainerId(_containerId);
+        connectionSettingBuilder.SaslMechanism(SaslMechanism.Anonymous);
+
+        ConnectionSettings connectionSettings = connectionSettingBuilder.Build();
+        _connection = await AmqpConnection.CreateAsync(connectionSettings);
+
+        Assert.True(_connection.State == State.Open);
+    }
+}