148 |
try |
try |
149 |
{ |
{ |
150 |
//MQ Options |
//MQ Options |
151 |
Hashtable connProps = getConnectionProperties(); |
Hashtable connProps = MQHelper.getConnectionProperties(controller.mqHost, controller.mqChannel); |
152 |
int openOptions = MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING; |
int openOptions = MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING; |
153 |
|
|
154 |
//MySQL Options |
//MySQL Options |
209 |
} |
} |
210 |
finally |
finally |
211 |
{ |
{ |
212 |
|
MQHelper.closeQueueSafe(out_queue); |
213 |
|
MQHelper.closeQueueManagerSafe(mqMgr); |
214 |
|
|
|
if (out_queue != null && out_queue.IsOpen) |
|
|
{ |
|
|
try |
|
|
{ |
|
|
out_queue.Close(); |
|
|
} |
|
|
catch (Exception e) |
|
|
{ |
|
|
Console.WriteLine("Error cleaning up qmgr " + e.Message); |
|
|
} |
|
|
} |
|
|
|
|
|
if (mqMgr != null && mqMgr.IsOpen) |
|
|
{ |
|
|
try |
|
|
{ |
|
|
mqMgr.Close(); |
|
|
} |
|
|
catch (Exception e) |
|
|
{ |
|
|
Console.WriteLine("Error cleaning up qmgr " + e.Message); |
|
|
} |
|
|
} |
|
215 |
|
|
216 |
} |
} |
217 |
} |
} |
227 |
try |
try |
228 |
{ |
{ |
229 |
//MQ options |
//MQ options |
230 |
Hashtable connProps = getConnectionProperties(); |
Hashtable connProps = MQHelper.getConnectionProperties(controller.mqHost, controller.mqChannel); |
231 |
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING; |
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING; |
232 |
|
|
233 |
//MySQL options |
//MySQL options |
263 |
|
|
264 |
// Hvis transaktionen starter med et ? er det ikke en gyldig transaktion |
// Hvis transaktionen starter med et ? er det ikke en gyldig transaktion |
265 |
// validér ligeledes at headeren er gyldig |
// validér ligeledes at headeren er gyldig |
266 |
if ( msgString.StartsWith("?") || Salt2Helper.validateSalt2Header(msgString) == false ) |
if ( Salt2Helper.validateSalt2Header(msgString) == false ) |
267 |
{ |
{ |
268 |
string discarded_filename = Logfile.getLogFilename(LogfileType.LogTransactions, controller.logDirectory, name); |
string discarded_filename = Logfile.getLogFilename(LogfileType.LogTransactions, controller.logDirectory, name); |
269 |
using (StreamWriter discardedlog = new StreamWriter(discarded_filename, true)) |
using (StreamWriter discardedlog = new StreamWriter(discarded_filename, true)) |
359 |
finally |
finally |
360 |
{ |
{ |
361 |
|
|
362 |
if (in_queue != null && in_queue.IsOpen) |
MQHelper.closeQueueSafe(in_queue); |
363 |
{ |
MQHelper.closeQueueManagerSafe(mqMgr); |
|
try |
|
|
{ |
|
|
in_queue.Close(); |
|
|
} |
|
|
catch (Exception e) |
|
|
{ |
|
|
Console.WriteLine("Error cleaning up qmgr " + e.Message); |
|
|
} |
|
|
} |
|
|
|
|
|
if (mqMgr != null && mqMgr.IsOpen) |
|
|
{ |
|
|
try |
|
|
{ |
|
|
mqMgr.Close(); |
|
|
} catch (Exception e) { |
|
|
Console.WriteLine("Error cleaning up qmgr " + e.Message); |
|
|
} |
|
|
} |
|
364 |
|
|
365 |
} |
} |
366 |
} |
} |
379 |
return connectionString; |
return connectionString; |
380 |
} |
} |
381 |
|
|
|
private Hashtable getConnectionProperties() |
|
|
{ |
|
|
Hashtable connProperties = new Hashtable(); |
|
|
connProperties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_CLIENT); |
|
|
connProperties.Add(MQC.HOST_NAME_PROPERTY, controller.mqHost); |
|
|
connProperties.Add(MQC.CHANNEL_PROPERTY, controller.mqChannel); |
|
|
return connProperties; |
|
|
} |
|
|
|
|
382 |
|
|
383 |
} |
} |
384 |
} |
} |