|
28 | 28 | public class TestConsumerLoader |
29 | 29 | { |
30 | 30 | // Local |
31 | | - private static final String CONSUMER_ID = "StudentConsumer"; |
| 31 | +// private static final String CONSUMER_ID = "StudentConsumer"; |
32 | 32 | // private static final String CONSUMER_ID = "RicOneConsumer"; |
33 | 33 |
|
34 | 34 | // Broker |
35 | 35 | // private static final String CONSUMER_ID = "BrokeredAttTrackerConsumer"; |
36 | | -// private static final String CONSUMER_ID = "QueueTestConsumer"; |
| 36 | + private static final String CONSUMER_ID = "QueueTestConsumer"; |
37 | 37 |
|
38 | 38 |
|
39 | 39 | public void stopService(String serviceID) |
@@ -92,22 +92,22 @@ public static void main(String[] args) |
92 | 92 |
|
93 | 93 | // Put this agent to a blocking wait..... |
94 | 94 | long waitTime = 20; // seconds |
95 | | - tester.doWait(waitTime); |
| 95 | +// tester.doWait(waitTime); // to test shutdown procedure |
96 | 96 |
|
97 | | -// try |
98 | | -// { |
99 | | -// Object semaphore = new Object(); |
100 | | -// synchronized (semaphore) // this will block until CTRL-C is pressed. |
101 | | -// { |
102 | | -// System.out.println("==================================================\nTestConsumerLoader is running (Press Ctrl-C to stop)\n=================================================="); |
103 | | -// semaphore.wait(); |
104 | | -// } |
105 | | -// } |
106 | | -// catch (Exception ex) |
107 | | -// { |
108 | | -// System.out.println("Blocking wait in TestConsumerLoader interrupted: " + ex.getMessage()); |
109 | | -// ex.printStackTrace(); |
110 | | -// } |
| 97 | + try |
| 98 | + { |
| 99 | + Object semaphore = new Object(); |
| 100 | + synchronized (semaphore) // this will block until CTRL-C is pressed. |
| 101 | + { |
| 102 | + System.out.println("==================================================\nTestConsumerLoader is running (Press Ctrl-C to stop)\n=================================================="); |
| 103 | + semaphore.wait(); |
| 104 | + } |
| 105 | + } |
| 106 | + catch (Exception ex) |
| 107 | + { |
| 108 | + System.out.println("Blocking wait in TestConsumerLoader interrupted: " + ex.getMessage()); |
| 109 | + ex.printStackTrace(); |
| 110 | + } |
111 | 111 |
|
112 | 112 | ConsumerLoader.shutdown(); |
113 | 113 |
|
|
0 commit comments