Allow exchange type to be a string

Fixes #66

Author: lukebakken

RabbitMQ.AMQP.Client/IEntities.cs

@@ -149,8 +149,9 @@ public interface IExchangeSpecification : IEntitySpecification
         bool IsAutoDelete { get; }
         IExchangeSpecification AutoDelete(bool isAutoDelete);
 
-        ExchangeType ExchangeType { get; }
+        string ExchangeType { get; }
         IExchangeSpecification Type(ExchangeType exchangeType);
+        IExchangeSpecification Type(string exchangeType);
 
         Dictionary<string, object> ExchangeArguments { get; }
         IExchangeSpecification Argument(string key, object value);

RabbitMQ.AMQP.Client/Impl/AmqpExchangeSpecification.cs

@@ -22,7 +22,7 @@ public AmqpExchangeSpecification(AmqpManagement management)
 
         private string _name = "";
         private bool _autoDelete;
-        private ExchangeType _type = Client.ExchangeType.DIRECT;
+        private string _exchangeType = Client.ExchangeType.DIRECT.ToString();
         private readonly Map _arguments = new();
 
         public Task DeclareAsync()
@@ -36,7 +36,7 @@ public Task DeclareAsync()
             {
                 { "auto_delete", _autoDelete },
                 { "arguments", _arguments },
-                { "type", _type.ToString().ToLower() },
+                { "type", _exchangeType.ToLowerInvariant() },
                 { "durable", true }
             };
 
@@ -75,13 +75,19 @@ public IExchangeSpecification AutoDelete(bool autoDelete)
 
         public bool IsAutoDelete => _autoDelete;
 
-        public IExchangeSpecification Type(ExchangeType type)
+        public IExchangeSpecification Type(ExchangeType exchangeType)
         {
-            _type = type;
+            _exchangeType = exchangeType.ToString();
             return this;
         }
 
-        public ExchangeType ExchangeType => _type;
+        public IExchangeSpecification Type(string exchangeType)
+        {
+            _exchangeType = exchangeType;
+            return this;
+        }
+
+        public string ExchangeType => _exchangeType;
 
         public IExchangeSpecification Argument(string key, object value)
         {

RabbitMQ.AMQP.Client/Impl/RecordingTopologyListener.cs

@@ -142,7 +142,7 @@ internal ExchangeSpec(IExchangeSpecification exchangeSpecification)
 
         internal string ExchangeName => _exchangeSpecification.ExchangeName;
 
-        internal ExchangeType ExchangeType => _exchangeSpecification.ExchangeType;
+        internal string ExchangeType => _exchangeSpecification.ExchangeType;
 
         internal bool IsAutoDelete => _exchangeSpecification.IsAutoDelete;
 

RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt

@@ -155,10 +155,11 @@ RabbitMQ.AMQP.Client.IExchangeSpecification.Arguments(System.Collections.Generic
 RabbitMQ.AMQP.Client.IExchangeSpecification.AutoDelete(bool isAutoDelete) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
 RabbitMQ.AMQP.Client.IExchangeSpecification.ExchangeArguments.get -> System.Collections.Generic.Dictionary<string!, object!>!
 RabbitMQ.AMQP.Client.IExchangeSpecification.ExchangeName.get -> string!
-RabbitMQ.AMQP.Client.IExchangeSpecification.ExchangeType.get -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.IExchangeSpecification.ExchangeType.get -> string!
 RabbitMQ.AMQP.Client.IExchangeSpecification.IsAutoDelete.get -> bool
 RabbitMQ.AMQP.Client.IExchangeSpecification.Name(string! exchangeName) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
 RabbitMQ.AMQP.Client.IExchangeSpecification.Type(RabbitMQ.AMQP.Client.ExchangeType exchangeType) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IExchangeSpecification.Type(string! exchangeType) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
 RabbitMQ.AMQP.Client.ILifeCycle
 RabbitMQ.AMQP.Client.ILifeCycle.ChangeState -> RabbitMQ.AMQP.Client.LifeCycleCallBack!
 RabbitMQ.AMQP.Client.ILifeCycle.CloseAsync() -> System.Threading.Tasks.Task!
@@ -262,10 +263,11 @@ RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.DeclareAsync() -> System.Thr
 RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.DeleteAsync() -> System.Threading.Tasks.Task!
 RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.ExchangeArguments.get -> System.Collections.Generic.Dictionary<string!, object!>!
 RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.ExchangeName.get -> string!
-RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.ExchangeType.get -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.ExchangeType.get -> string!
 RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.IsAutoDelete.get -> bool
 RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Name(string! name) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
-RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Type(RabbitMQ.AMQP.Client.ExchangeType type) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Type(RabbitMQ.AMQP.Client.ExchangeType exchangeType) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Type(string! exchangeType) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpManagement
 RabbitMQ.AMQP.Client.Impl.AmqpManagement.Binding() -> RabbitMQ.AMQP.Client.IBindingSpecification!
 RabbitMQ.AMQP.Client.Impl.AmqpManagement.Exchange() -> RabbitMQ.AMQP.Client.IExchangeSpecification!

Tests/Management/ManagementTests.cs

@@ -295,6 +295,24 @@ public async Task SimpleDeclareAndDeleteExchangeWithName()
         await SystemUtils.WaitUntilExchangeDeletedAsync(exchangeSpec);
     }
 
+    [Fact]
+    public async Task DeclareAndDeleteExchangeWithStringType()
+    {
+        Assert.NotNull(_connection);
+        Assert.NotNull(_management);
+
+        IExchangeSpecification exchangeSpec = _management.Exchange(_exchangeName).Type("direct");
+        await exchangeSpec.DeclareAsync();
+
+        await _management.Exchange(_exchangeName).Type("direct").DeclareAsync();
+
+        await SystemUtils.WaitUntilExchangeExistsAsync(exchangeSpec);
+
+        await exchangeSpec.DeleteAsync();
+
+        await SystemUtils.WaitUntilExchangeDeletedAsync(exchangeSpec);
+    }
+
     [Fact]
     public async Task ExchangeWithEmptyNameShouldRaiseAnException()
     {