接收java推送的数据

AppStart/RabbitMQClient.cs

@@ -245,6 +245,7 @@ namespace MySystem
             consumer.Received += (a, e) =>
             {
                 string MsgContent = Encoding.Default.GetString(e.Body.ToArray());
+                RedisDbconn.Instance.AddList("JavaUrlDataQueue", MsgContent);
                 function.WriteLog(MsgContent, "接收mq接口数据队列");
                 if(ApiDataFromJavaService.Instance.ApiDataDo(MsgContent))
                 {

Startup.cs

@@ -141,10 +141,8 @@ namespace MySystem
             MpMerchantActService.Instance.Start();
             KxsOrderService.Instance.Start();
             KxsActService.Instance.Start();
-            KxsActService.Instance.StartMp();
-
-            
-            // RabbitMQClient.Instance.StartReceiveApi("QUEUE_DTS_URL_DATA_DIVISION");
+            KxsActService.Instance.StartMp();            
+            RabbitMQClient.Instance.StartReceiveApi("QUEUE_DTS_URL_DATA_DIVISION");
         }
     }
 }