human detection: region

opencv-yolo/web/web.py

@@ -78,19 +78,25 @@ if RABBITMQ_URI:
     connection = pika.BlockingConnection(parameters)
     rabChan = connection.channel()
     rabChan.exchange_declare(exchange=RABBITMQ_EXHANGE, exchange_type="topic")
-    rabChan.queue_declare(queue=RABBITMQ_TOPIC, durable=False)
+    qr = rabChan.queue_declare('', durable=False)
     rabChan.queue_bind(exchange=RABBITMQ_EXHANGE,
-                    queue=RABBITMQ_TOPIC)
+                    queue=qr.method.queue, routing_key=RABBITMQ_TOPIC)
     rabChan.basic_consume(
-        queue=RABBITMQ_TOPIC, on_message_callback=rabCallback, auto_ack=True)
+        queue=qr.method.queue, on_message_callback=rabCallback, auto_ack=True)
 
 print("CONFIG: \n\tMQTT: {}:{}\n\tBIN_NAME: {}".format(
     MQTT_HOST, MQTT_PORT, binName))
 
 def rabCallback(ch, method, prop, body):
-    pass
-
-
+    try:
+        rk = method.routing_key.split('.')
+        sn = None
+        if len(rk):
+            sn = rk[0]
+        if sn:
+            CAMERA_CONFIG_MAP[sn] = json.loads(body)
+    except Exception as e:
+        print("failed to process callback: {} - {}", method, body)
 
 def downloadFile(ipcSn, dirName, fileName, destDir):
     file_path = ipcSn + '/'+dirName+'/'+fileName