init

src/main/java/com/cx/cn/cxquartz/redis/OrderConsumer.java

@@ -83,13 +83,13 @@ public class OrderConsumer implements  Consumer {
                          "}";
                 //抽帧结果放到rabbttmq 中，根据msg 的检测metatype ,分别派发到不同的queue中，方便以后10条10条的去皮皮昂分析
                 Map m = new HashMap();
-//                m.put("deviceSnapshot", JsonUtil.objToStr(msg));
-//                m.put("result", result);
+                m.put("taskparam", JsonUtil.objToStr(msg));
+                m.put("result", result);
                 String msgId = UUID.randomUUID().toString();
                 CorrelationData correlationData = new CorrelationData(msgId);
                 orderConsumer.rabbitTemplate.convertAndSend(QueueConstants.QueueTaskEnum.QUEUE_TASK_ENUM.getExchange(),
                         QueueConstants.QueueTaskEnum.QUEUE_TASK_ENUM.getRouteKey()+"_"+msg.getObjectType(),
-                        MessageHelper.objToMsg(result),
+                        MessageHelper.objToMsg(m),
                         correlationData);
 
 //                  String roistr= URLEncoder.encode("[")+msg.getObjectx()+","+msg.getObjecty()+","+msg.getObjectw()+","+msg.getObjecth()+URLEncoder.encode("]");