Allow amqps:// URLs

mythz · mythz · commit 4e64bfc88345 · 2019-11-07T12:43:20.000-05:00
diff --git a/src/ServiceStack.RabbitMq/RabbitMqMessageFactory.cs b/src/ServiceStack.RabbitMq/RabbitMqMessageFactory.cs
@@ -45,7 +45,7 @@ public RabbitMqMessageFactory(string connectionString = "localhost",
             if (password != null)
                 ConnectionFactory.Password = password;
 
-            if (connectionString.StartsWith("amqp://"))
+            if (connectionString.StartsWith("amqp://") || connectionString.StartsWith("amqps://"))
             {
                 ConnectionFactory.Uri = new Uri(connectionString);
             }

Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ public RabbitMqMessageFactory(string connectionString = "localhost",`
`45`	`45`	`if (password != null)`
`46`	`46`	`ConnectionFactory.Password = password;`
`47`	`47`
`48`		`- if (connectionString.StartsWith("amqp://"))`
	`48`	`+ if (connectionString.StartsWith("amqp://") \|\| connectionString.StartsWith("amqps://"))`
`49`	`49`	`{`
`50`	`50`	`ConnectionFactory.Uri = new Uri(connectionString);`
`51`	`51`	`}`