DaoMqPump2/DaoMqPump2/TransportController.cs

using System;
using System.Collections.Generic;
using System.IO;

using Microsoft.Win32;

namespace DaoMqPump2
{
    public class TransportController
    {
        List<Transport> transports = new List<Transport>();

        public string mysqlHost { get; private set; }
        public string mysqlPort { get; private set; }
        public string mysqlUser { get; private set; }
        public string mysqlPassword { get; private set; }

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

        public string logDirectory { get; private set; }

        
        protected TransportController()
        {
            initialize();
        }

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

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

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

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

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


            //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");

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

            //Læs alle transport indstillingerne
            string[] transportNames = key.GetSubKeyNames();
            foreach (string name in transportNames)
            {
                Console.WriteLine("Reading Transport: " + name);
                RegistryKey subKey = key.OpenSubKey(name);

                string direction = (string)subKey.GetValue("Direction");
                if (direction == null || direction.Length == 0)
                    throw new System.ArgumentException(name + ".direction cannot be null or empty");
                direction = direction.ToLower();

                if (direction.Equals(Transport.MQ2SQL) == false && direction.Equals(Transport.SQL2MQ) == false)
                    throw new System.ArgumentException(name + ".direction invalid value (sql2mq OR mq2sql) : " + direction);


                string queueName = (string)subKey.GetValue("MQQueueName");
                if (queueName == null || queueName.Length == 0)
                    throw new System.ArgumentException(name + ".MQQueueName cannot be null or empty");

                Object tmpEnabled = subKey.GetValue("Enabled");
                if (tmpEnabled == null)
                    throw new System.ArgumentException(name + ".Enabled cannot be null or empty");
                bool enabled = ((int)tmpEnabled > 0);


                string mq2sqlInsertQuery = "";
                string sql2mqReadQuery = "";
                string sql2mqUpdateQuery = "";


                if (direction == "mq2sql")
                {
                    mq2sqlInsertQuery = (string)subKey.GetValue("Mq2sqlInsertQuery");
                    if (mq2sqlInsertQuery == null || mq2sqlInsertQuery.Length == 0)
                        throw new System.ArgumentException(name + ".Mq2sqlInsertQuery cannot be null or empty");
                }
                else // sql2mq
                {
                    sql2mqReadQuery = (string)subKey.GetValue("Sql2mqReadQuery");
                    if (sql2mqReadQuery == null || sql2mqReadQuery.Length == 0)
                        throw new System.ArgumentException(name + ".Sql2mqReadQuery cannot be null or empty");

                    sql2mqUpdateQuery = (string)subKey.GetValue("Sql2mqUpdateQuery");
                    if (sql2mqUpdateQuery == null || sql2mqUpdateQuery.Length == 0)
                        throw new System.ArgumentException(name + ".Sql2mqUpdateQuery cannot be null or empty");
                }

                Transport trans = new Transport(this, name, direction, queueName, mq2sqlInsertQuery, sql2mqReadQuery, sql2mqUpdateQuery, enabled);

                transports.Add(trans);
            }


        }

        public void transportAllMessages()
        {
            Console.WriteLine("transportAllMessages()");
            foreach (Transport trans in transports)
            {
                trans.transportMessages();
            }
        }

        public string[] getTransportNames()
        {
            List<string> names = new List<string>();

            foreach (Transport t in transports)
            {
                names.Add(t.name);
            }

            return names.ToArray();
        }

        public Transport getTransport(string name)
        {
            foreach (Transport t in transports)
            {
                if (t.name == name)//found requested Transport object
                {
                    return t;
                }
            }
            return null;
        }


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

            return instance;
        }

    }
}
1	torben	1986	using System;
2			using System.Collections.Generic;
3			using System.IO;
4
5			using Microsoft.Win32;
6
7			namespace DaoMqPump2
8			{
9			public class TransportController
10			{
11			List<Transport> transports = new List<Transport>();
12
13			public string mysqlHost { get; private set; }
14			public string mysqlPort { get; private set; }
15			public string mysqlUser { get; private set; }
16			public string mysqlPassword { get; private set; }
17
18			public string mqHost { get; private set; }
19			public string mqChannel { get; private set; }
20			public string mqQueueManager { get; private set; }
21
22			public string logDirectory { get; private set; }
23
24
25
26			protected TransportController()
27			{
28			initialize();
29			}
30
31			private void initialize()
32			{
33			Console.WriteLine("TransportController: Loading config");
34			RegistryKey key = Registry.LocalMachine.CreateSubKey("Software\\DAO\\DaoMqPump2");
35
36			//Læser globale MySQL Parametre
37			mysqlHost = (string) key.GetValue("MysqlHost");
38			if (mysqlHost == null \|\| mysqlHost.Length == 0)
39			throw new System.ArgumentException("MysqlHost cannot be null or empty");
40
41			mysqlPort = (string) key.GetValue("MysqlPort");
42			if (mysqlPort == null \|\| mysqlPort.Length == 0)
43			throw new System.ArgumentException("MysqlPort cannot be null or empty");
44
45			mysqlUser = (string) key.GetValue("MysqlUser");
46			if (mysqlUser == null \|\| mysqlUser.Length == 0)
47			throw new System.ArgumentException("MysqlUser cannot be null or empty");
48
49			mysqlPassword = (string) key.GetValue("MysqlPassword");
50			if (mysqlPassword == null \|\|mysqlPassword.Length == 0)
51			throw new System.ArgumentException("MysqlPassword cannot be null or empty");
52
53
54			//Læser globale MQ Parametre
55			mqHost = (string)key.GetValue("MQHost");
56			if (mqHost == null \|\| mqHost.Length == 0)
57			throw new System.ArgumentException("MQHost cannot be null or empty");
58
59			mqChannel = (string)key.GetValue("MQChannel");
60			if (mqChannel == null \|\| mqChannel.Length == 0)
61			throw new System.ArgumentException("MQChannel cannot be null or empty");
62
63			mqQueueManager = (string)key.GetValue("MQQueueManager");
64			if (mqQueueManager == null \|\| mqQueueManager.Length == 0)
65			throw new System.ArgumentException("MQQueueManager cannot be null or empty");
66
67			//Læser øvrige parametre
68
69			logDirectory = (string)key.GetValue("LogDirectory");
70			if (logDirectory == null \|\| logDirectory.Length == 0)
71			throw new System.ArgumentException("LogDirectory cannot be null or empty");
72
73			if (Directory.Exists(logDirectory) == false)
74			{
75			Directory.CreateDirectory(logDirectory);
76			}
77
78			//Læs alle transport indstillingerne
79			string[] transportNames = key.GetSubKeyNames();
80			foreach (string name in transportNames)
81			{
82			Console.WriteLine("Reading Transport: " + name);
83			RegistryKey subKey = key.OpenSubKey(name);
84
85			string direction = (string)subKey.GetValue("Direction");
86			if (direction == null \|\| direction.Length == 0)
87			throw new System.ArgumentException(name + ".direction cannot be null or empty");
88			direction = direction.ToLower();
89
90			if (direction.Equals(Transport.MQ2SQL) == false && direction.Equals(Transport.SQL2MQ) == false)
91			throw new System.ArgumentException(name + ".direction invalid value (sql2mq OR mq2sql) : " + direction);
92
93
94			string queueName = (string)subKey.GetValue("MQQueueName");
95			if (queueName == null \|\| queueName.Length == 0)
96			throw new System.ArgumentException(name + ".MQQueueName cannot be null or empty");
97
98			Object tmpEnabled = subKey.GetValue("Enabled");
99			if (tmpEnabled == null)
100			throw new System.ArgumentException(name + ".Enabled cannot be null or empty");
101			bool enabled = ((int)tmpEnabled > 0);
102
103
104			string mq2sqlInsertQuery = "";
105			string sql2mqReadQuery = "";
106			string sql2mqUpdateQuery = "";
107
108
109			if (direction == "mq2sql")
110			{
111			mq2sqlInsertQuery = (string)subKey.GetValue("Mq2sqlInsertQuery");
112			if (mq2sqlInsertQuery == null \|\| mq2sqlInsertQuery.Length == 0)
113			throw new System.ArgumentException(name + ".Mq2sqlInsertQuery cannot be null or empty");
114			}
115			else // sql2mq
116			{
117			sql2mqReadQuery = (string)subKey.GetValue("Sql2mqReadQuery");
118			if (sql2mqReadQuery == null \|\| sql2mqReadQuery.Length == 0)
119			throw new System.ArgumentException(name + ".Sql2mqReadQuery cannot be null or empty");
120
121			sql2mqUpdateQuery = (string)subKey.GetValue("Sql2mqUpdateQuery");
122			if (sql2mqUpdateQuery == null \|\| sql2mqUpdateQuery.Length == 0)
123			throw new System.ArgumentException(name + ".Sql2mqUpdateQuery cannot be null or empty");
124			}
125
126			Transport trans = new Transport(this, name, direction, queueName, mq2sqlInsertQuery, sql2mqReadQuery, sql2mqUpdateQuery, enabled);
127
128			transports.Add(trans);
129			}
130
131
132			}
133
134			public void transportAllMessages()
135			{
136			Console.WriteLine("transportAllMessages()");
137			foreach (Transport trans in transports)
138			{
139			trans.transportMessages();
140			}
141			}
142
143			public string[] getTransportNames()
144			{
145			List<string> names = new List<string>();
146
147			foreach (Transport t in transports)
148			{
149			names.Add(t.name);
150			}
151
152			return names.ToArray();
153			}
154
155			public Transport getTransport(string name)
156			{
157			foreach (Transport t in transports)
158			{
159			if (t.name == name)//found requested Transport object
160			{
161			return t;
162			}
163			}
164			return null;
165			}
166
167
168			/* Singleton */
169			private static TransportController instance = null;
170			public static TransportController getInstance()
171			{
172			if (instance == null)
173			instance = new TransportController();
174
175			return instance;
176			}
177
178			}
179			}