diff --git a/src/mod/event_handlers/mod_amqp/mod_amqp_connection.c b/src/mod/event_handlers/mod_amqp/mod_amqp_connection.c
index 7aa3095765..8e8be16389 100644
--- a/src/mod/event_handlers/mod_amqp/mod_amqp_connection.c
+++ b/src/mod/event_handlers/mod_amqp/mod_amqp_connection.c
@@ -234,6 +234,7 @@ switch_status_t mod_amqp_connection_create(mod_amqp_connection_t **conn, switch_
 void mod_amqp_connection_destroy(mod_amqp_connection_t **conn)
 {
 	if (conn && *conn) {
+		mod_amqp_connection_close(*conn);
 		*conn = NULL;
 	}
 }