--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/org/dancres/blitz/util/QueueStatGenerator.java	Sat Mar 21 11:00:06 2009 +0000
@@ -0,0 +1,32 @@
+package org.dancres.blitz.util;
+
+import org.dancres.blitz.stats.StatGenerator;
+import org.dancres.blitz.stats.Stat;
+import org.dancres.blitz.stats.TaskQueueStat;
+import EDU.oswego.cs.dl.util.concurrent.BoundedLinkedQueue;
+
+/**
+ */
+public class QueueStatGenerator implements StatGenerator {
+    private long theId = StatGenerator.UNSET_ID;
+
+    private String _queueName;
+    private BoundedLinkedQueue _channel;
+    
+    public QueueStatGenerator(String aName, BoundedLinkedQueue aQueue) {
+        _queueName = aName;
+        _channel = aQueue;
+    }
+
+    public long getId() {
+        return theId;
+    }
+
+    public void setId(long anId) {
+        theId = anId;
+    }
+
+    public Stat generate() {
+        return new TaskQueueStat(theId, _queueName, _channel.size());
+    }
+}