1 files changed, 2 insertions, 7 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c
index 392ed62..f3552e9 100644
--- a/librabbitmq/amqp_connection.c
+++ b/librabbitmq/amqp_connection.c
@@ -448,13 +448,8 @@ int amqp_send_frame(amqp_connection_state_t state,
     amqp_e32(out_frame, 3, out_frame_len);
     amqp_e8(out_frame, out_frame_len + HEADER_SIZE, AMQP_FRAME_END);
     res = amqp_socket_send(state->socket, out_frame,
-                           out_frame_len + HEADER_SIZE + FOOTER_SIZE,
-                           MSG_NOSIGNAL);
+                           out_frame_len + HEADER_SIZE + FOOTER_SIZE);
   }
 
-  if (res < 0) {
-    return amqp_socket_error(state->socket);
-  } else {
-    return AMQP_STATUS_OK;
-  }
+  return res;
 }