1 |
torben |
2163 |
using System;
|
2 |
|
|
using System.Collections.Generic;
|
3 |
torben |
2167 |
using System.IO;
|
4 |
|
|
using System.Text.RegularExpressions;
|
5 |
torben |
2163 |
|
6 |
torben |
2167 |
using Microsoft.Win32;
|
7 |
|
|
|
8 |
torben |
2163 |
namespace MQFilter
|
9 |
|
|
{
|
10 |
|
|
class FilterController
|
11 |
|
|
{
|
12 |
|
|
|
13 |
torben |
2167 |
public string mqHost { get; private set; }
|
14 |
|
|
public string mqChannel { get; private set; }
|
15 |
|
|
public string mqQueueManager { get; private set; }
|
16 |
|
|
|
17 |
|
|
public string logDirectory { get; private set; }
|
18 |
|
|
|
19 |
|
|
public string[] filterTranscations { get; private set; }
|
20 |
|
|
|
21 |
|
|
|
22 |
|
|
protected FilterController()
|
23 |
|
|
{
|
24 |
|
|
initialize();
|
25 |
|
|
}
|
26 |
|
|
|
27 |
|
|
private void initialize()
|
28 |
|
|
{
|
29 |
|
|
Console.WriteLine("FilterController: Loading config");
|
30 |
|
|
RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\MQFilter");
|
31 |
|
|
|
32 |
|
|
|
33 |
|
|
//Læser globale MQ Parametre
|
34 |
|
|
mqHost = (string)key.GetValue("MQHost");
|
35 |
|
|
if (mqHost == null || mqHost.Length == 0)
|
36 |
|
|
throw new System.ArgumentException("MQHost cannot be null or empty");
|
37 |
|
|
|
38 |
|
|
mqChannel = (string)key.GetValue("MQChannel");
|
39 |
|
|
if (mqChannel == null || mqChannel.Length == 0)
|
40 |
|
|
throw new System.ArgumentException("MQChannel cannot be null or empty");
|
41 |
|
|
|
42 |
|
|
mqQueueManager = (string)key.GetValue("MQQueueManager");
|
43 |
|
|
if (mqQueueManager == null || mqQueueManager.Length == 0)
|
44 |
|
|
throw new System.ArgumentException("MQQueueManager cannot be null or empty");
|
45 |
|
|
|
46 |
|
|
//Læser øvrige parametre
|
47 |
|
|
|
48 |
|
|
logDirectory = (string)key.GetValue("LogDirectory");
|
49 |
|
|
if (logDirectory == null || logDirectory.Length == 0)
|
50 |
|
|
throw new System.ArgumentException("LogDirectory cannot be null or empty");
|
51 |
|
|
|
52 |
|
|
String tmpFilterTransactions = (string)key.GetValue("FilterTransactions");
|
53 |
|
|
if (tmpFilterTransactions == null || tmpFilterTransactions.Length == 0)
|
54 |
|
|
throw new System.ArgumentException("LogDirectory cannot be null or empty");
|
55 |
|
|
filterTranscations = Regex.Split( tmpFilterTransactions, "," );
|
56 |
|
|
|
57 |
|
|
for (int i = 0; i < filterTranscations.Length; i++)
|
58 |
|
|
{
|
59 |
|
|
filterTranscations[i] = filterTranscations[i].Trim();
|
60 |
|
|
}
|
61 |
|
|
|
62 |
|
|
|
63 |
|
|
if (Directory.Exists(logDirectory) == false)
|
64 |
|
|
{
|
65 |
|
|
Directory.CreateDirectory(logDirectory);
|
66 |
|
|
}
|
67 |
|
|
|
68 |
|
|
}
|
69 |
|
|
|
70 |
|
|
|
71 |
|
|
|
72 |
torben |
2163 |
public void transportAllMessages()
|
73 |
|
|
{
|
74 |
|
|
}
|
75 |
|
|
|
76 |
torben |
2167 |
|
77 |
|
|
|
78 |
torben |
2163 |
/* Singleton */
|
79 |
|
|
private static FilterController instance = null;
|
80 |
|
|
public static FilterController getInstance()
|
81 |
|
|
{
|
82 |
|
|
if (instance == null)
|
83 |
|
|
instance = new FilterController();
|
84 |
|
|
|
85 |
|
|
return instance;
|
86 |
|
|
}
|
87 |
|
|
|
88 |
|
|
}
|
89 |
|
|
}
|