16 |
class FilterController |
class FilterController |
17 |
{ |
{ |
18 |
|
|
19 |
|
public const int TRANSACTIONS_PER_RUN = 2000; |
20 |
|
|
21 |
public string mqHost { get; private set; } |
public string mqHost { get; private set; } |
22 |
public string mqChannel { get; private set; } |
public string mqChannel { get; private set; } |
23 |
public string mqQueueManager { get; private set; } |
public string mqQueueManager { get; private set; } |
227 |
|
|
228 |
|
|
229 |
messageCount++;// increment per run message counter |
messageCount++;// increment per run message counter |
230 |
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 |
231 |
{ |
{ |
232 |
isContinue = false; |
isContinue = false; |
233 |
} |
} |
283 |
|
|
284 |
if (now >= silentPeriodBegin && now < silentPeriodEnd) |
if (now >= silentPeriodBegin && now < silentPeriodEnd) |
285 |
{ |
{ |
286 |
|
|
287 |
|
if (header.afsender == "DAO") //DAO transaktioner må altid komme igennem |
288 |
|
return false; |
289 |
|
|
290 |
if (contains(header.transaktionForkortelse, this.filterTranscations) ) //Så længe vi skal være .net3.0 kompatible er LINQ problematisk (LINQ kræver 3.5) |
if (contains(header.transaktionForkortelse, this.filterTranscations) ) //Så længe vi skal være .net3.0 kompatible er LINQ problematisk (LINQ kræver 3.5) |
291 |
{ |
{ |