| 4 |
|
//---IMPORTS--- |
| 5 |
|
import uk.ac.ukc.iscream.util.*; |
| 6 |
|
import uk.ac.ukc.iscream.core.*; |
| 7 |
+ |
import uk.ac.ukc.iscream.componentmanager.*; |
| 8 |
|
import uk.ac.ukc.iscream.clientinterface.*; |
| 9 |
|
|
| 10 |
|
/** |
| 18 |
|
* @author $Author$ |
| 19 |
|
* @version $Id$ |
| 20 |
|
*/ |
| 21 |
< |
public class RootFilter implements uk.ac.ukc.iscream.util.Component { |
| 21 |
> |
public class RootFilter implements Component { |
| 22 |
|
|
| 23 |
|
//---FINAL ATTRIBUTES--- |
| 24 |
|
|
| 103 |
|
_refman.bindToOrb(filterServant, "iscream.Filter." + RootFilter.NAME); |
| 104 |
|
|
| 105 |
|
_logger.write(toString(), Logger.SYSINIT, "started"); |
| 106 |
+ |
|
| 107 |
+ |
// !!!! TEMPORARY CODE !!!! |
| 108 |
+ |
// Monitor the queue's status (queue 0 and 1 - big assumption!) |
| 109 |
+ |
while(true) { |
| 110 |
+ |
// wait 30 seconds |
| 111 |
+ |
try { Thread.sleep(30000); } catch(Exception e) {} |
| 112 |
+ |
try { |
| 113 |
+ |
int q0 = queue.queueSize(0); |
| 114 |
+ |
int q1 = queue.queueSize(1); |
| 115 |
+ |
int tot = queue.elementCount(); |
| 116 |
+ |
String message = "Queue status - queue0: "+q0+" queue1: "+q1+" total: "+tot; |
| 117 |
+ |
_logger.write(toString(), Logger.DEBUG, message); |
| 118 |
+ |
} |
| 119 |
+ |
catch(Exception e) { |
| 120 |
+ |
_logger.write(toString(), Logger.ERROR, e.getMessage()); |
| 121 |
+ |
} |
| 122 |
+ |
} |
| 123 |
|
} |
| 124 |
|
|
| 125 |
|
/** |
