DaoMqPump2/DaoMqPump2/MainProgram.cs

using System;
using System.Collections;
using System.Text;

using System.ServiceProcess;
using System.Diagnostics;

using System.Configuration.Install;
using System.Collections.Specialized;
using System.Runtime.InteropServices;

using DaoCommon;

//Create a Console App - remember to add the System.ServiceProcess assembly to references

namespace DaoMqPump2
{


    class MainProgram
    {
        public enum LoadLibraryFlags : uint
        {
            DONT_RESOLVE_DLL_REFERENCES = 0x00000001,
            LOAD_IGNORE_CODE_AUTHZ_LEVEL = 0x00000010,
            LOAD_LIBRARY_AS_DATAFILE = 0x00000002,
            LOAD_LIBRARY_AS_DATAFILE_EXCLUSIVE = 0x00000040,
            LOAD_LIBRARY_AS_IMAGE_RESOURCE = 0x00000020,
            LOAD_WITH_ALTERED_SEARCH_PATH = 0x00000008
        }

        [DllImport("Kernel32.dll", CallingConvention = CallingConvention.StdCall)]
        public static extern bool AddDllDirectory(String lpPathName);
        
        [DllImport("kernel32.dll")]
        static extern IntPtr LoadLibraryEx(string lpFileName, IntPtr hReservedNull, LoadLibraryFlags dwFlags);


        static void Main(string[] args)
        {
            //AddDllDirectory("c:\\Program Files\\IBM\\Websphere MQ\\bin");

            /*string libPath = "c:\\Program Files\\IBM\\Websphere MQ\\bin\\mqic32.dll";

            IntPtr res = LoadLibraryEx(libPath, IntPtr.Zero, LoadLibraryFlags.LOAD_WITH_ALTERED_SEARCH_PATH);

            if (res == IntPtr.Zero)
            {
                EventLog.WriteEntry("DaoMqPump2", "error loading " + libPath, EventLogEntryType.Warning);
                Console.WriteLine("Error loading library");
                Console.ReadKey(); //wait for user input
                return;
            }*/

            if (args.Length == 1)
            {
                if (args[0] == "--debug")
                {                    
                    try
                    {
                        

                        TransportController controller = TransportController.getInstance();

                        ElapsedTimer timer = new ElapsedTimer();
                        controller.transportAllMessages();

                        timer.stopAndPrint("debug run");

                        PumpService s = new PumpService();

                        s.startRemoteControl();
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine("Error: " + e.Message);
                    }

                    
                    Console.WriteLine("Press any key to continue");
                    Console.ReadKey(); //wait for user input
                } 
                else if (args[0] == "/i" || args[0] == "/u")
                {

                    bool undo;
                    if (args[0] == "/i")
                    {
                        undo = false;
                    }
                    else
                    {
                        undo = true;
                    }
                    MyServiceInstaller.DoInstall(undo, new string[] { });                
                }
                else
                {
                    Console.WriteLine("DaoMqPumpv2 by THN");
                    Console.WriteLine("Options:");
                    Console.WriteLine("  --debug    start a single run debug session");
                    Console.WriteLine("  /i         install as a service");
                    Console.WriteLine("  /u         un-install service");
                }

            }
            else
            {
                PumpService service = new PumpService();


                // now run all the service that we have created.
                // This doesn't actually cause the services
                // to run but it registers the services with the
                // Service Control Manager so that it can
                // when you start the service the SCM will call
                // the OnStart method of the service.

                ServiceBase.Run(service);
            }

        }
    }
}
1	torben	1986	using System;
2			using System.Collections;
3			using System.Text;
4
5			using System.ServiceProcess;
6			using System.Diagnostics;
7
8			using System.Configuration.Install;
9			using System.Collections.Specialized;
10			using System.Runtime.InteropServices;
11
12	torben	2161	using DaoCommon;
13
14	torben	1986	//Create a Console App - remember to add the System.ServiceProcess assembly to references
15
16			namespace DaoMqPump2
17			{
18
19
20			class MainProgram
21			{
22			public enum LoadLibraryFlags : uint
23			{
24			DONT_RESOLVE_DLL_REFERENCES = 0x00000001,
25			LOAD_IGNORE_CODE_AUTHZ_LEVEL = 0x00000010,
26			LOAD_LIBRARY_AS_DATAFILE = 0x00000002,
27			LOAD_LIBRARY_AS_DATAFILE_EXCLUSIVE = 0x00000040,
28			LOAD_LIBRARY_AS_IMAGE_RESOURCE = 0x00000020,
29			LOAD_WITH_ALTERED_SEARCH_PATH = 0x00000008
30			}
31
32			[DllImport("Kernel32.dll", CallingConvention = CallingConvention.StdCall)]
33			public static extern bool AddDllDirectory(String lpPathName);
34
35			[DllImport("kernel32.dll")]
36			static extern IntPtr LoadLibraryEx(string lpFileName, IntPtr hReservedNull, LoadLibraryFlags dwFlags);
37
38
39			static void Main(string[] args)
40			{
41			//AddDllDirectory("c:\\Program Files\\IBM\\Websphere MQ\\bin");
42
43			/*string libPath = "c:\\Program Files\\IBM\\Websphere MQ\\bin\\mqic32.dll";
44
45			IntPtr res = LoadLibraryEx(libPath, IntPtr.Zero, LoadLibraryFlags.LOAD_WITH_ALTERED_SEARCH_PATH);
46
47			if (res == IntPtr.Zero)
48			{
49			EventLog.WriteEntry("DaoMqPump2", "error loading " + libPath, EventLogEntryType.Warning);
50			Console.WriteLine("Error loading library");
51			Console.ReadKey(); //wait for user input
52			return;
53			}*/
54
55			if (args.Length == 1)
56			{
57			if (args[0] == "--debug")
58	torben	2062	{
59	torben	1986	try
60			{
61	torben	2062
62
63	torben	1986	TransportController controller = TransportController.getInstance();
64	torben	2062
65	torben	2070	ElapsedTimer timer = new ElapsedTimer();
66	torben	1986	controller.transportAllMessages();
67	torben	2005
68	torben	2070	timer.stopAndPrint("debug run");
69	torben	2062
70	torben	2005	PumpService s = new PumpService();
71
72			s.startRemoteControl();
73	torben	1986	}
74			catch (Exception e)
75			{
76			Console.WriteLine("Error: " + e.Message);
77			}
78
79	torben	2062
80
81
82
83	torben	1986	Console.WriteLine("Press any key to continue");
84			Console.ReadKey(); //wait for user input
85	torben	2049	}
86			else if (args[0] == "/i" \|\| args[0] == "/u")
87	torben	1986	{
88
89			bool undo;
90			if (args[0] == "/i")
91			{
92			undo = false;
93			}
94			else
95			{
96			undo = true;
97			}
98			MyServiceInstaller.DoInstall(undo, new string[] { });
99			}
100	torben	2049	else
101			{
102			Console.WriteLine("DaoMqPumpv2 by THN");
103			Console.WriteLine("Options:");
104			Console.WriteLine(" --debug start a single run debug session");
105			Console.WriteLine(" /i install as a service");
106			Console.WriteLine(" /u un-install service");
107			}
108	torben	1986
109			}
110			else
111			{
112			PumpService service = new PumpService();
113
114
115			// now run all the service that we have created.
116			// This doesn't actually cause the services
117			// to run but it registers the services with the
118			// Service Control Manager so that it can
119			// when you start the service the SCM will call
120			// the OnStart method of the service.
121
122			ServiceBase.Run(service);
123			}
124
125			}
126			}
127			}