|
@@ -50,6 +50,8 @@ public abstract class QueueHandler extends Thread implements Comparator<QueueIte
|
50
|
50
|
* @param out Writer to send to.
|
51
|
51
|
*/
|
52
|
52
|
public QueueHandler(final OutputQueue outputQueue, final BlockingQueue<QueueItem> queue, final PrintWriter out) {
|
|
53
|
+ super("IRC Parser queue handler");
|
|
54
|
+
|
53
|
55
|
this.queue = queue;
|
54
|
56
|
this.out = out;
|
55
|
57
|
this.outputQueue = outputQueue;
|
|
@@ -97,6 +99,7 @@ public abstract class QueueHandler extends Thread implements Comparator<QueueIte
|
97
|
99
|
* @param otherObject Object we are comparing to.
|
98
|
100
|
* @return A QueueItem for teh given parameters
|
99
|
101
|
*/
|
|
102
|
+ @Override
|
100
|
103
|
public int compare(final QueueItem mainObject, final QueueItem otherObject) {
|
101
|
104
|
if (mainObject.getTime() < 10 * 1000 && mainObject.getPriority().compareTo(otherObject.getPriority()) != 0) {
|
102
|
105
|
return mainObject.getPriority().compareTo(otherObject.getPriority());
|