diff options
Diffstat (limited to 'librabbitmq')
| -rw-r--r-- | librabbitmq/amqp_socket.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index a63a0b6..f4e536a 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -480,6 +480,12 @@ int amqp_open_socket_inner(char const *hostname, continue; } + if (0 != amqp_os_socket_setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE, &one, + sizeof(one))) { + last_error = AMQP_STATUS_SOCKET_ERROR; + continue; + } + #ifdef _WIN32 res = connect(sockfd, addr->ai_addr, (int)addr->ai_addrlen); #else |