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.29 by tdb, Wed Mar 14 23:25:29 2001 UTC vs.
Revision 1.30 by tdb, Fri Mar 16 16:11:32 2001 UTC

# Line 58 | Line 58 | public class FilterMain implements Component {
58          }
59          
60          // setup a queue
61 <        Queue queue = new Queue();
61 >        Queue queue;
62 >        // see if this Queue needs a size limit
63 >        try {
64 >            int queueSizeLimit = Integer.parseInt(cp.getProperty(FilterMain.NAME, "Queue.SizeLimit"));
65 >            String queueRemoveAlgorithm = cp.getProperty(FilterMain.NAME, "Queue.RemoveAlgorithm");
66 >            int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
67 >            if(algorithm != -1) {
68 >                _logger.write(toString(), Logger.DEBUG, "Starting Queue with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
69 >                // we have valid values, so lets start it.
70 >                queue = new Queue(queueSizeLimit, algorithm);
71 >            }
72 >            else {
73 >                _logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
74 >                // just don't activate a limit
75 >                queue = new Queue();
76 >            }
77 >            
78 >        } catch (PropertyNotFoundException e) {
79 >            _logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
80 >            // just don't activate a limit
81 >            queue = new Queue();
82 >        } catch (NumberFormatException e) {
83 >            _logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
84 >            // just don't activate a limit
85 >            queue = new Queue();
86 >        }
87          
88          // startup a monitor on this queue
89          try {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines