45 |
try |
try |
46 |
{ |
{ |
47 |
transportController = TransportController.getInstance(); |
transportController = TransportController.getInstance(); |
|
} |
|
|
catch (Exception e) |
|
|
{ |
|
|
EventLog.WriteEntry("DaoMqPump2", "Error starting DaoMqPump2: " + e.Message, EventLogEntryType.Error); |
|
|
throw e; |
|
|
} |
|
48 |
|
|
49 |
|
// create our threadstart object to wrap our delegate method |
50 |
|
ThreadStart ts = new ThreadStart(this.ServiceWorkerMethod); |
51 |
|
|
52 |
// create our threadstart object to wrap our delegate method |
// create the manual reset event and |
53 |
ThreadStart ts = new ThreadStart(this.ServiceWorkerMethod); |
// set it to an initial state of unsignaled |
54 |
|
m_shutdownEvent = new ManualResetEvent(false); |
55 |
|
|
56 |
// create the manual reset event and |
// create the worker thread |
57 |
// set it to an initial state of unsignaled |
m_thread = new Thread(ts); |
|
m_shutdownEvent = new ManualResetEvent(false); |
|
58 |
|
|
59 |
// create the worker thread |
// go ahead and start the worker thread |
60 |
m_thread = new Thread(ts); |
m_thread.Start(); |
61 |
|
|
|
// go ahead and start the worker thread |
|
|
m_thread.Start(); |
|
62 |
|
|
63 |
|
startRemoteControl(); |
64 |
|
|
65 |
startRemoteControl(); |
} |
66 |
|
catch (Exception e) |
67 |
|
{ |
68 |
|
EventLog.WriteEntry("DaoMqPump2", "Error starting DaoMqPump2: " + e.Message, EventLogEntryType.Error); |
69 |
|
throw e; |
70 |
|
} |
71 |
} |
} |
72 |
|
|
73 |
// Stop this service. |
// Stop this service. |