Change the default port to amqps when -S given

hassansin · Dec 4, 2021 · df544aa · df544aa
1 parent 7adf7c4
commit df544aa
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cmd/root.go b/cmd/root.go
@@ -40,6 +40,12 @@ func getUri() string {
 	var proto string = "amqp://"
 	if (ssl) {
 		proto = "amqps://"
+		// Change the port from amqp default to amqps default.
+		// not sure how to check if -P flag was given by the user
+		// so the perverse situtation where amqps runs on port 5672 would not work sorry
+		if (port == 5672) {
+			port = 5671
+		}
 	}
 	return proto + username + ":" + password + "@" + host + ":" + strconv.Itoa(port) + vhost
 }