| # | Line 140 | Line 140 | class TCPControlHandler extends Thread { | |
|---|---|---|
| 140 | TCPDataHandler dh = new TCPDataHandler(s); | |
| 141 | // register the DataHandler's queue, giving the host list | |
| 142 | _packetSorter.register(dh.getQueue(), _hostList); | |
| 143 | + | // startup a monitor on the DataHandler's queue, every minute |
| 144 | + | dh.getQueue().startMonitor(60*1000, _packetSorter.getQueue(), _name); |
| 145 | // start up the DataHandler | |
| 146 | dh.start(); | |
| 147 | // Hold a reference to the DataHandler, so we can stop it later | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |