object detection: revise

opencv-yolo/web/web.py

@@ -130,9 +130,9 @@ def rabbit_ai_task():
 
         # ai analysis task channel
         rabChanAiTask = connection.channel()
+        rabChanAiTask.queue_declare(queue=AI_QUEUE_TASK, durable=True)
         if AI_EXCHANGE:
             rabChanAiTask.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
-        rabChanAiTask.queue_declare(queue=AI_QUEUE_TASK, durable=True)
             rabChanAiTask.queue_bind(exchange=AI_EXCHANGE,
                             queue=AI_QUEUE_TASK, routing_key=AI_QUEUE_TASK)
         rabChanAiTask.basic_consume(
@@ -366,9 +366,9 @@ def video_analysis(data):
         parameters = pika.URLParameters(RABBITMQ_URI)
         connection = pika.BlockingConnection(parameters)
         rabChanResult = connection.channel()
-        rabChanResult.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
         rabChanResult.queue_declare(queue=AI_QUEUE_RESULT, durable=True)
         if AI_EXCHANGE:
+            rabChanResult.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
             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),