add connection timeout

integrationWorker.py

@@ -298,15 +298,18 @@ if __name__ == "__main__":
     signal.signal(signal.SIGHUP, stop_integration_worker)
 
     try:
-        while not STOP_GLOBAL_LOOP:
-            connection = BlockingConnection(AMQP_SERVER)
+        while True:
+            connection = BlockingConnection(AMQP_SERVER, timeout=5)
             receiver = connection.create_receiver(QUEUE)
-            message = receiver.receive(timeout=30)
+            message = receiver.receive()
             receiver.accept()
             transaction_process(message)
             connection.close()
-    except (KeyboardInterrupt, Timeout):
+    except KeyboardInterrupt:
         pass
+    except (Timeout):
+        print("Connection or reception timeout")
+        logging.info("Connection or reception timeout")
 
     logging.critical("integration worker quitting")
     sys.exit(1)