Add a role for collectd/fcomm-queue

roles/collectd/fcomm-queue/files/fcomm-queue-collectd.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python
+import retask.queue
+import socket
+import time
+
+interval = 2
+
+hostname = socket.gethostname().split('.')[0]
+
+queue = retask.queue.Queue('fedora-packages')
+queue.connect()
+
+while True:
+    print "PUTVAL %s/redis/queue_length interval=%i %i:%i" % (
+        hostname,
+        interval,
+        int(time.time()),
+        queue.length,
+    )
+    time.sleep(interval)