报错之后不需要再次进入消息队列

PushInfo.Core/BLL/ProcessTaskBLL.cs

@@ -596,12 +596,12 @@ namespace PushInfo.Core.BLL
         {
             try
             {
-                ConfirmSendTask(mapProPush, data);
-                //if (mapProPush.Push_Style.IndexOf(((int)PushStyle.APP).ToString()) > -1)
-                //    MqNameTwo = MqName;
-                //else if (mapProPush.Push_Style.IndexOf(((int)PushStyle.极光App).ToString()) > -1)
-                //    MqNameTwo = MqNameUrora;
-                //ActiveMQHelper.CreateMQProducer(MqNameTwo, MQMode.Queue, new DataCenterMessage { ObjectID = "", MsgData = mapProPush.ToJson(), MsgSecondData = data.ToJson() }, sendDate);
+                //ConfirmSendTask(mapProPush, data);
+                if (mapProPush.Push_Style.IndexOf(((int)PushStyle.APP).ToString()) > -1)
+                    MqNameTwo = MqName;
+                else if (mapProPush.Push_Style.IndexOf(((int)PushStyle.极光App).ToString()) > -1)
+                    MqNameTwo = MqNameUrora;
+                ActiveMQHelper.CreateMQProducer(MqNameTwo, MQMode.Queue, new DataCenterMessage { ObjectID = "", MsgData = mapProPush.ToJson(), MsgSecondData = data.ToJson() }, sendDate);
             }
             catch (Exception e)
             {
@@ -637,14 +637,14 @@ namespace PushInfo.Core.BLL
                             LogHelper.Debug(ex.Message);
                         }
                         if (result.Result != 1 && result.code == 1)
-                            TaskIntoMq(mapProPush, data, DateTime.Now.AddSeconds(10));
+                            //TaskIntoMq(mapProPush, data, DateTime.Now.AddSeconds(10));
                         Console.WriteLine(mapProPush.Push_Title + "：" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                     }
                 }
                 catch (Exception ex)
                 {
                     LogHelper.Debug(ex.Message);
-                    TaskIntoMq(JsonHelper.ToObject<Map_Project_Push>(msg.MsgData), JsonHelper.ToObject<DataMessage>(msg.MsgSecondData), DateTime.Now.AddSeconds(10));
+                    //TaskIntoMq(JsonHelper.ToObject<Map_Project_Push>(msg.MsgData), JsonHelper.ToObject<DataMessage>(msg.MsgSecondData), DateTime.Now.AddSeconds(10));
                 }
             });
         }