/[projects]/dao/DaoMqPump2/MQFilter/FilterController.cs
ViewVC logotype

Diff of /dao/DaoMqPump2/MQFilter/FilterController.cs

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

revision 2174 by torben, Sat May 17 11:25:26 2014 UTC revision 2175 by torben, Mon May 19 11:59:45 2014 UTC
# Line 45  namespace MQFilter Line 45  namespace MQFilter
45              //Læser globale MQ Parametre              //Læser globale MQ Parametre
46              mqHost = (string)key.GetValue("MQHost");              mqHost = (string)key.GetValue("MQHost");
47              if (mqHost == null || mqHost.Length == 0)              if (mqHost == null || mqHost.Length == 0)
48                {
49                    key.SetValue("MQHost", "", RegistryValueKind.String);
50                  throw new System.ArgumentException("MQHost cannot be null or empty");                  throw new System.ArgumentException("MQHost cannot be null or empty");
51                }
52    
53              mqChannel = (string)key.GetValue("MQChannel");              mqChannel = (string)key.GetValue("MQChannel");
54              if (mqChannel == null || mqChannel.Length == 0)              if (mqChannel == null || mqChannel.Length == 0)
55                {
56                    key.SetValue("MQChannel", "", RegistryValueKind.String);
57                  throw new System.ArgumentException("MQChannel cannot be null or empty");                  throw new System.ArgumentException("MQChannel cannot be null or empty");
58                }
59    
60              mqQueueManager = (string)key.GetValue("MQQueueManager");              mqQueueManager = (string)key.GetValue("MQQueueManager");
61              if (mqQueueManager == null || mqQueueManager.Length == 0)              if (mqQueueManager == null || mqQueueManager.Length == 0)
62                {
63                    key.SetValue("MQQueueManager", "", RegistryValueKind.String);
64                  throw new System.ArgumentException("MQQueueManager cannot be null or empty");                  throw new System.ArgumentException("MQQueueManager cannot be null or empty");
65                }
66    
67              ////////////              ////////////
68    
69              logDirectory = (string)key.GetValue("LogDirectory");              logDirectory = (string)key.GetValue("LogDirectory");
70              if (logDirectory == null || logDirectory.Length == 0)              if (logDirectory == null || logDirectory.Length == 0)
71                {
72                    key.SetValue("LogDirectory", "", RegistryValueKind.String);
73                  throw new System.ArgumentException("LogDirectory cannot be null or empty");                  throw new System.ArgumentException("LogDirectory cannot be null or empty");
74                }
75    
76              if (Directory.Exists(logDirectory) == false)              if (Directory.Exists(logDirectory) == false)
77              {              {
# Line 70  namespace MQFilter Line 82  namespace MQFilter
82    
83              String tmpFilterTransactions = (string)key.GetValue("FilterTransactions");              String tmpFilterTransactions = (string)key.GetValue("FilterTransactions");
84              if (tmpFilterTransactions == null || tmpFilterTransactions.Length == 0)              if (tmpFilterTransactions == null || tmpFilterTransactions.Length == 0)
85                {
86                    key.SetValue("FilterTransactions", "", RegistryValueKind.String);
87                  throw new System.ArgumentException("FilterTransactions cannot be null or empty");                  throw new System.ArgumentException("FilterTransactions cannot be null or empty");
88                }
89              tmpFilterTransactions = tmpFilterTransactions.Replace(';', ',');              tmpFilterTransactions = tmpFilterTransactions.Replace(';', ',');
90              filterTranscations = Regex.Split(tmpFilterTransactions, ",");              filterTranscations = Regex.Split(tmpFilterTransactions, ",");
91    
# Line 107  namespace MQFilter Line 122  namespace MQFilter
122                  //MQ objects i v6 implementerer ikke IDisposable og kan derfor ikke bruges med "using" statement                  //MQ objects i v6 implementerer ikke IDisposable og kan derfor ikke bruges med "using" statement
123                  mqMgr = new MQQueueManager(mqQueueManager, connProps);//stage 1 connect to mq                  mqMgr = new MQQueueManager(mqQueueManager, connProps);//stage 1 connect to mq
124    
                 queueIndbakke = mqMgr.AccessQueue(queueNameIndbakke, openInputOptions);  
125    
126                  queueMysql = mqMgr.AccessQueue(queueNameMysql, openOutputOptions);                  queueIndbakke = MQHelper.openQueueHelper(queueNameIndbakke, mqMgr, openInputOptions);
127                  queueDimaps = mqMgr.AccessQueue(queueNameDimaps, openOutputOptions);  
128                  queueStore = mqMgr.AccessQueue(queueNameStore, openOutputOptions);                  queueMysql = MQHelper.openQueueHelper(queueNameMysql, mqMgr, openOutputOptions);
129                    queueDimaps = MQHelper.openQueueHelper(queueNameDimaps, mqMgr, openOutputOptions);
130                    queueStore = MQHelper.openQueueHelper(queueNameStore, mqMgr, openOutputOptions);
131    
132    
133                  bool isContinue = true;                  bool isContinue = true;
Legend:
Removed from v.2174  
changed lines
  Added in v.2175
  ViewVC Help
Powered by ViewVC 1.1.20