diff options
-rw-r--r-- | librabbitmq/amqp_openssl.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index 85b9ca5..c1b5515 100644 --- a/librabbitmq/amqp_openssl.c +++ b/librabbitmq/amqp_openssl.c @@ -81,6 +81,10 @@ amqp_ssl_socket_send(void *base, { struct amqp_ssl_socket_t *self = (struct amqp_ssl_socket_t *)base; ssize_t res; + if (-1 == self->sockfd) { + return AMQP_STATUS_SOCKET_CLOSED; + } + ERR_clear_error(); self->internal_error = 0; |