109 |
|
while(true) { |
110 |
|
// wait 30 seconds |
111 |
|
try { Thread.sleep(30000); } catch(Exception e) {} |
112 |
< |
int q0 = _queue.queueSize(0); |
113 |
< |
int q1 = _queue.queueSize(1); |
114 |
< |
int tot = _queue.elementCount(); |
115 |
< |
String message = "Queue status - queue1: "+q1+" queue2: "+q2+" total: "+tot; |
112 |
> |
int q0 = queue.queueSize(0); |
113 |
> |
int q1 = queue.queueSize(1); |
114 |
> |
int tot = queue.elementCount(); |
115 |
> |
String message = "Queue status - queue0: "+q0+" queue1: "+q1+" total: "+tot; |
116 |
|
_logger.write(toString(), Logger.DEBUG, message); |
117 |
|
} |
118 |
|
} |