rabbitmq port updated as adjustable.

byerlikaya · Oct 10, 2024 · d07c0f8 · d07c0f8
1 parent 5d56f04
commit d07c0f8
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -28,7 +28,8 @@ builder.Services.AddRabbitMqClient(Configuration);
     "UserName": "",
     "Password": "",
     "ExchangeName": "",
-    "VirtualHost": ""
+    "VirtualHost": "",
+    "Port": -1
   }
 ```
 

diff --git a/src/Basic.RabbitMQ/Extensions/ServiceCollectionExtensions.cs b/src/Basic.RabbitMQ/Extensions/ServiceCollectionExtensions.cs
@@ -28,6 +28,7 @@ private static void CreateServices(
             UserName = messageBrokerOptions.Username,
             Password = messageBrokerOptions.Password,
             VirtualHost = messageBrokerOptions.VirtualHost,
+            Port = messageBrokerOptions.Port is default(int) ? AmqpTcpEndpoint.UseDefaultPort : messageBrokerOptions.Port,
             DispatchConsumersAsync = true,
             AutomaticRecoveryEnabled = true,
             NetworkRecoveryInterval = TimeSpan.FromSeconds(30),

diff --git a/src/Basic.RabbitMQ/Options/MessageBrokerOptions.cs b/src/Basic.RabbitMQ/Options/MessageBrokerOptions.cs
@@ -7,4 +7,5 @@ public class MessageBrokerOptions
     public string Password { get; set; }
     public string ExchangeName { get; set; }
     public string VirtualHost { get; set; }
+    public int Port { get; set; }
 }