diff options
| -rw-r--r-- | librabbitmq/amqp_socket.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index a5bbd4b..6e06fbd 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -498,7 +498,7 @@ int amqp_open_socket_inner(char const *hostname, int portnumber, for (addr = address_list; addr; addr = addr->ai_next) { sockfd = connect_socket(addr, deadline); - if (sockfd > 0) { + if (sockfd >= 0) { last_error = AMQP_STATUS_OK; break; } else if (sockfd == AMQP_STATUS_TIMEOUT) { |