Fixes to alternate SSL backends to not crash

1 files changed, 9 insertions, 0 deletions

diff --git a/librabbitmq/amqp_cyassl.c b/librabbitmq/amqp_cyassl.c
index 2fa83e6..1c078e9 100644
--- a/librabbitmq/amqp_cyassl.c
+++ b/librabbitmq/amqp_cyassl.c
@@ -32,6 +32,7 @@
 #include <string.h>
 
 struct amqp_ssl_socket_t {
+  const struct amqp_socket_class_t *klass;
   CYASSL_CTX *ctx;
   CYASSL *ssl;
   int sockfd;
@@ -154,6 +155,13 @@ amqp_ssl_socket_open(void *base, const char *host, int port)
   struct amqp_ssl_socket_t *self = (struct amqp_ssl_socket_t *)base;
   int status;
   self->last_error = 0;
+
+  self->ssl = CyaSSL_new(self->ctx);
+  if (NULL == self->ssl) {
+    self->last_error = ERROR_CATEGORY_SSL;
+    return -1;
+  }
+
   self->sockfd = amqp_open_socket(host, port);
   if (0 > self->sockfd) {
     self->last_error = - self->sockfd;
@@ -190,6 +198,7 @@ amqp_ssl_socket_new(void)
   if (!self->ctx) {
     goto error;
   }
+  self->klass = &amqp_ssl_socket_class;
   return (amqp_socket_t *)self;
 error:
   amqp_socket_close((amqp_socket_t *)self);