ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java (file contents):
Revision 1.22 by tdb, Mon Feb 12 02:22:48 2001 UTC vs.
Revision 1.23 by tdb, Wed Feb 21 19:11:30 2001 UTC

# Line 49 | Line 49 | public class FilterMain implements Component {
49          int UDPListenPort = 0;
50          int TCPListenPort = 0;
51          String parentFilterName = null;
52 +        int queueMonitorInterval = 0;
53          
54          Configuration config = _refman.getCM().getConfiguration(FilterMain.NAME);
55          if (config == null) {
# Line 60 | Line 61 | public class FilterMain implements Component {
61                  UDPListenPort = Integer.parseInt(config.getProperty("Filter.UDPListenPort"));
62                  TCPListenPort = Integer.parseInt(config.getProperty("Filter.TCPListenPort"));
63                  parentFilterName = config.getProperty("Filter.parentFilter");
64 +                queueMonitorInterval = Integer.parseInt(config.getProperty("Queue.MonitorInterval"));
65              } catch (org.omg.CORBA.MARSHAL e) {
66                  throw new ComponentStartException("Unable to obtain requried configuration property for component");
67              }
# Line 73 | Line 75 | public class FilterMain implements Component {
75          // setup a queue
76          Queue queue = new Queue();
77          // startup a monitor on this queue, every minute
78 <        queue.startMonitor(60*1000, NAME);
78 >        String queueName = NAME + " Filter";
79 >        queue.startMonitor(queueMonitorInterval*1000, queueName);
80          
81          // Start a filter thread
82          _logger.write(toString(), Logger.SYSINIT, "starting Filter Thread / Queue consumer");

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines