Add amqp_end_connection, which closes the socket and destroys the connection

1 files changed, 9 insertions, 0 deletions

diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c
index 8623eed..7531fac 100644
--- a/librabbitmq/amqp_connection.c
+++ b/librabbitmq/amqp_connection.c
@@ -170,6 +170,15 @@ void amqp_destroy_connection(amqp_connection_state_t state) {
   free(state);
 }
 
+int amqp_end_connection(amqp_connection_state_t state) {
+  int s = state->sockfd;
+  amqp_destroy_connection(state);
+  if (close(s) < 0)
+    return -errno;
+  else
+    return 0;
+} 
+
 static void return_to_idle(amqp_connection_state_t state) {
   state->inbound_buffer.bytes = NULL;
   state->inbound_offset = 0;