diff --git a/neon_mq_connector/utils/client_utils.py b/neon_mq_connector/utils/client_utils.py
index ccd165a..2c8c175 100644
--- a/neon_mq_connector/utils/client_utils.py
+++ b/neon_mq_connector/utils/client_utils.py
@@ -60,6 +60,8 @@ def __init__(self, config: dict, service_name: str, vhost: str):
     def shutdown(self):
         MQConnector.stop(self)
         self.connection.close()
+        if not self.connection.is_closed:
+            raise RuntimeError(f"Connection is still open: {self.connection}")
 
 
 def send_mq_request(vhost: str, request_data: dict, target_queue: str,