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;

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

                        long start = DateTime.Now.Ticks;
                        controller.transportAllMessages();
                        long stop = DateTime.Now.Ticks;

                        long elapsed = (stop - start) / 10000; //omreg tidsforskel til millisekunder

                        Console.WriteLine("Run took " + elapsed + " milliseconds ");

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