diff options
Diffstat (limited to 'librabbitmq/amqp_tcp_socket.c')
| -rw-r--r-- | librabbitmq/amqp_tcp_socket.c | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/librabbitmq/amqp_tcp_socket.c b/librabbitmq/amqp_tcp_socket.c index 2eb366f..1a155bb 100644 --- a/librabbitmq/amqp_tcp_socket.c +++ b/librabbitmq/amqp_tcp_socket.c @@ -76,7 +76,12 @@ amqp_tcp_socket_close(void *base) status = amqp_os_socket_close(self->sockfd); free(self); } - return status; + + if (0 == status) { + return AMQP_STATUS_OK; + } else { + return AMQP_STATUS_SOCKET_ERROR; + } } static int |