Optionally set ca cert path (#309)

Co-authored-by: Paul Morgan <[email protected]>
alanxz · Jul 25, 2022 · 6369b99 · 6369b99
1 parent f1344fb
commit 6369b99
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/src/Channel.cpp b/src/Channel.cpp
@@ -421,11 +421,14 @@ Channel::ChannelImpl *Channel::OpenSecureChannel(
 #endif
 
   try {
-    int status =
-        amqp_ssl_socket_set_cacert(socket, tls_params.ca_cert_path.c_str());
-    if (status) {
-      throw AmqpLibraryException::CreateException(
-          status, "Error setting CA certificate for socket");
+    int status;
+    if (tls_params.ca_cert_path != "") {
+      status =
+          amqp_ssl_socket_set_cacert(socket, tls_params.ca_cert_path.c_str());
+      if (status) {
+        throw AmqpLibraryException::CreateException(
+            status, "Error setting CA certificate for socket");
+      }
     }
 
     if (tls_params.client_key_path != "" && tls_params.client_cert_path != "") {