object detection: revise

opencv-yolo/web/web_rabbit.py

@@ -357,21 +357,24 @@ def video_analysis(data):
         mc.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
     mc.connect(MQTT_HOST, MQTT_PORT)
     mc.publish('video.ai/v1.0/result', json.dumps(ret), qos=1)
+    print("mqtt message published")
     # rabbitmq
     if RABBITMQ_URI:
         parameters = pika.URLParameters(RABBITMQ_URI)
         connection = pika.BlockingConnection(parameters)
         rabChanResult = connection.channel()
-        if AI_EXCHANGE:
         rabChanResult.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
+        rabChanResult.queue_declare(queue=AI_QUEUE_RESULT, durable=True)
+        rabChanResult.queue_bind(exchange=AI_EXCHANGE,
+                        queue=AI_QUEUE_RESULT, routing_key=AI_QUEUE_RESULT)
         rabChanResult.basic_publish(exchange =AI_EXCHANGE,routing_key=AI_QUEUE_RESULT,body=json.dumps(ret),
             properties=pika.BasicProperties(delivery_mode = 2))
+        print("rabbitmq message published")
         rabChanResult.close()
     try:
         os.system('rm -fr ' + downloadDir)
     except Exception as e:
         print('cascaded exception in va: {}'.format(e))
-        #raise Exception()
 
     return ret