--- dao/DaoMqPump2/MQFilter/FilterController.cs 2014/05/20 20:12:15 2180 +++ dao/DaoMqPump2/MQFilter/FilterController.cs 2014/05/21 09:56:21 2183 @@ -16,6 +16,8 @@ class FilterController { + public const int TRANSACTIONS_PER_RUN = 2000; + public string mqHost { get; private set; } public string mqChannel { get; private set; } public string mqQueueManager { get; private set; } @@ -134,6 +136,7 @@ catch (Exception e) { logFile.addSingleLogEntry("Error during transportAllMessages: " + e.Message); + Console.WriteLine(e.StackTrace); } } @@ -180,8 +183,12 @@ queueIndbakke.Get(mqMsg, mqGetMsgOpts); if (mqMsg.Format.CompareTo(MQC.MQFMT_STRING) == 0) { + if (mqMsg.MessageLength == 0) //Skip empty transactions (so far only seen on my test server) + continue; + + //System.Console.WriteLine("LEN>" + mqMsg.MessageLength); string salt2String = mqMsg.ReadString(mqMsg.MessageLength); - //System.Console.WriteLine(msgString); + // validér at headeren er gyldig @@ -220,7 +227,7 @@ messageCount++;// increment per run message counter - if (messageCount >= 10000) // if we have moved 10000 messages in this run - let it go + if (messageCount >= TRANSACTIONS_PER_RUN) // if we have moved TRANSACTIONS_PER_RUN messages in this run - let it go { isContinue = false; } @@ -276,6 +283,9 @@ if (now >= silentPeriodBegin && now < silentPeriodEnd) { + + if (header.afsender == "DAO") //DAO transaktioner må altid komme igennem + return false; if (contains(header.transaktionForkortelse, this.filterTranscations) ) //Så længe vi skal være .net3.0 kompatible er LINQ problematisk (LINQ kræver 3.5) {