DaoMqPump2/DaoMqPump2/RemoteControl.cs

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

namespace DaoMqPump2
{
    public class RemoteControl : IRemoteControl
    {
        

        public string[] GetTransports()
        {
            TransportController controller = TransportController.getInstance();
            return controller.getTransportNames();
        }


        public bool GetTransportEnabled(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.enabled;
        }


        public void SetTransportEnabled(string transport, bool enabled) 
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            t.enabled = enabled;
        }
        

        public bool GetTransportLastrunOk(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.lastrunOk;
        }

        public string GetTransportLastErrorMessage(string transport)
        {
            TransportController controller = TransportController.getInstance();
            Transport t = controller.getTransport(transport);
            return t.lastErrorMessage;
        }


        public string GetTransportLastOkTime(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.lastOkTime;
        }

        public string GetTransportLastErrorTime(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.lastErrorTime;
        }

        public int GetTransportCounter(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.counter;
        }

        
        public string[] GetTransportLog(string transport) 
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.getLog();

        }


        public string GetTransportDirection(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.direction;
        }


        public string GetTransportQueueName(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.queueName;
        }


        public string GetTransportInsertQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.mq2sqlInsertQuery;
        }


        public string GetTransportReadQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.sql2mqReadQuery;
        }


        public string GetTransportUpdateQuery(string transport)
        {
            Transport t = TransportController.getInstance().getTransport(transport);
            return t.sql2mqUpdateQuery;
        }


    }
}
1	using System;
2	using System.Collections.Generic;
3	using System.Text;
4
5	namespace DaoMqPump2
6	{
7	public class RemoteControl : IRemoteControl
8	{
9
10
11	public string[] GetTransports()
12	{
13	TransportController controller = TransportController.getInstance();
14	return controller.getTransportNames();
15	}
16
17
18	public bool GetTransportEnabled(string transport)
19	{
20	TransportController controller = TransportController.getInstance();
21	Transport t = controller.getTransport(transport);
22	return t.enabled;
23	}
24
25
26	public void SetTransportEnabled(string transport, bool enabled)
27	{
28	TransportController controller = TransportController.getInstance();
29	Transport t = controller.getTransport(transport);
30	t.enabled = enabled;
31	}
32
33
34	public bool GetTransportLastrunOk(string transport)
35	{
36	TransportController controller = TransportController.getInstance();
37	Transport t = controller.getTransport(transport);
38	return t.lastrunOk;
39	}
40
41	public string GetTransportLastErrorMessage(string transport)
42	{
43	TransportController controller = TransportController.getInstance();
44	Transport t = controller.getTransport(transport);
45	return t.lastErrorMessage;
46	}
47
48
49	public string GetTransportLastOkTime(string transport)
50	{
51	Transport t = TransportController.getInstance().getTransport(transport);
52	return t.lastOkTime;
53	}
54
55	public string GetTransportLastErrorTime(string transport)
56	{
57	Transport t = TransportController.getInstance().getTransport(transport);
58	return t.lastErrorTime;
59	}
60
61	public int GetTransportCounter(string transport)
62	{
63	Transport t = TransportController.getInstance().getTransport(transport);
64	return t.counter;
65	}
66
67
68	public string[] GetTransportLog(string transport)
69	{
70	Transport t = TransportController.getInstance().getTransport(transport);
71	return t.getLog();
72
73	}
74
75
76	public string GetTransportDirection(string transport)
77	{
78	Transport t = TransportController.getInstance().getTransport(transport);
79	return t.direction;
80	}
81
82
83	public string GetTransportQueueName(string transport)
84	{
85	Transport t = TransportController.getInstance().getTransport(transport);
86	return t.queueName;
87	}
88
89
90	public string GetTransportInsertQuery(string transport)
91	{
92	Transport t = TransportController.getInstance().getTransport(transport);
93	return t.mq2sqlInsertQuery;
94	}
95
96
97	public string GetTransportReadQuery(string transport)
98	{
99	Transport t = TransportController.getInstance().getTransport(transport);
100	return t.sql2mqReadQuery;
101	}
102
103
104	public string GetTransportUpdateQuery(string transport)
105	{
106	Transport t = TransportController.getInstance().getTransport(transport);
107	return t.sql2mqUpdateQuery;
108	}
109
110
111	}
112	}