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 |
{ |
{ |
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 |
|
|
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; |