diff --git a/create_account.py b/create_account.py
index 98d2dba8d74e092e1a1d3bdbb870f536161e3280..d5ae3a2a0e0ddcfef1d30e713fd905cfd486847d 100755
--- a/create_account.py
+++ b/create_account.py
@@ -34,7 +34,7 @@ if args.email == "":
 
 def timeout_handler(signum, frame):
     print("Process timeout, there's might some issue with agents")
-    rc_util.rc_rmq.stop_consume()
+    rc_util.rc_rmq.disconnect()
 
 
 def callback(channel, method, properties, body):
@@ -49,8 +49,7 @@ def callback(channel, method, properties, body):
         for err in errmsg:
             print(err)
 
-    rc_util.rc_rmq.stop_consume()
-    rc_util.rc_rmq.delete_queue()
+    rc_util.rc_rmq.disconnect()
 
 
 rc_util.add_account(