DaoMqPump2/MQFilter/FilterController.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Text.RegularExpressions;

using Microsoft.Win32;

namespace MQFilter
{
    class FilterController
    {

        public string mqHost { get; private set; }
        public string mqChannel { get; private set; }
        public string mqQueueManager { get; private set; }

        public string logDirectory { get; private set; }

        public string[] filterTranscations { get; private set; }


        protected FilterController()
        {
            initialize();
        }

        private void initialize()
        {
            Console.WriteLine("FilterController: Loading config");
            RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\MQFilter");


            //Læser globale MQ Parametre
            mqHost = (string)key.GetValue("MQHost");
            if (mqHost == null || mqHost.Length == 0)
                throw new System.ArgumentException("MQHost cannot be null or empty");

            mqChannel = (string)key.GetValue("MQChannel");
            if (mqChannel == null || mqChannel.Length == 0)
                throw new System.ArgumentException("MQChannel cannot be null or empty");

            mqQueueManager = (string)key.GetValue("MQQueueManager");
            if (mqQueueManager == null || mqQueueManager.Length == 0)
                throw new System.ArgumentException("MQQueueManager cannot be null or empty");

            //Læser øvrige parametre

            logDirectory = (string)key.GetValue("LogDirectory");
            if (logDirectory == null || logDirectory.Length == 0)
                throw new System.ArgumentException("LogDirectory cannot be null or empty");

            String tmpFilterTransactions = (string)key.GetValue("FilterTransactions");
            if (tmpFilterTransactions == null || tmpFilterTransactions.Length == 0)
                throw new System.ArgumentException("LogDirectory cannot be null or empty");
            filterTranscations = Regex.Split( tmpFilterTransactions, "," );

            for (int i = 0; i < filterTranscations.Length; i++)
            {
                filterTranscations[i] = filterTranscations[i].Trim();
            }


            if (Directory.Exists(logDirectory) == false)
            {
                Directory.CreateDirectory(logDirectory);
            }

        }


        public void transportAllMessages()
        {
        }


        /* Singleton */
        private static FilterController instance = null;
        public static FilterController getInstance()
        {
            if (instance == null)
                instance = new FilterController();

            return instance;
        }

    }
}
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			}