| # | Line 72 | Line 72 | public class FilterMain implements Component { | |
|---|---|---|
| 72 | ||
| 73 | // setup a queue | |
| 74 | Queue queue = new Queue(); | |
| 75 | + | // startup a monitor on this queue, every minute |
| 76 | + | queue.startMonitor(60*1000, NAME); |
| 77 | ||
| 78 | // Start a filter thread | |
| 79 | _logger.write(toString(), Logger.SYSINIT, "starting Filter Thread / Queue consumer"); | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |