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 |
} |
} |