/[projects]/dao/DaoMqPump2/DaoMqPump2/Transport.cs
ViewVC logotype

Diff of /dao/DaoMqPump2/DaoMqPump2/Transport.cs

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2135 by torben, Wed Nov 27 14:16:14 2013 UTC revision 2136 by torben, Wed Mar 26 14:00:14 2014 UTC
# Line 240  namespace DaoMqPump2 Line 240  namespace DaoMqPump2
240    
241          private void transportMq2Sql()          private void transportMq2Sql()
242          {          {
243                int messageCount = 0;
244    
245              MQQueueManager mqMgr = null;              MQQueueManager mqMgr = null;
246              MQQueue in_queue = null;              MQQueue in_queue = null;
247              string filename = getLogFilename(LogfileType.LogTransactions);              string filename = getLogFilename(LogfileType.LogTransactions);
# Line 306  namespace DaoMqPump2 Line 308  namespace DaoMqPump2
308                                          translog.WriteLine(getNowString() + " " + msgString);                                          translog.WriteLine(getNowString() + " " + msgString);
309                                          mqMgr.Commit();                                          mqMgr.Commit();
310                                          statusData.counter++;                                          statusData.counter++;
311    
312    
313                                            messageCount++;// increment per run message counter
314                                            if (messageCount >= 10000) // if we have moved  10000 messages in this run - let it go and give the other transports a change
315                                            {
316                                                isContinue = false;
317                                            }
318    
319    
320    
321                                      }                                      }
322                                      else                                      else
323                                      {                                      {
Legend:
Removed from v.2135  
changed lines
  Added in v.2136
  ViewVC Help
Powered by ViewVC 1.1.20