--- dao/DaoMqPump2/MQFilter/FilterController.cs 2014/05/20 20:48:48 2182 +++ 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; } @@ -225,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; }