vm: check all vmdriver queues

also display the queue statuses on node detail

Closes #426

circle/dashboard/templates/dashboard/node-detail.html

@@ -56,6 +56,11 @@
           <span class="label label-warning">{% trans "Offline" %}</span>
           <span class="label label-warning">{% trans "Offline" %}</span>
         {% endif %}
         {% endif %}
       </div>
       </div>
+      <div>
+        {% for k, v in queues.iteritems %}
+          <span class="label label-{% if v %}success{% else %}danger{% endif %}">{{ k }}</span>
+        {% endfor %}
+      </div>
     </div>
     </div>
     <div class="col-md-10" id="node-detail-pane">
     <div class="col-md-10" id="node-detail-pane">
       <div class="panel panel-default" id="node-detail-panel">
       <div class="panel panel-default" id="node-detail-panel">

circle/dashboard/views/node.py

@@ -37,6 +37,7 @@ from django_tables2 import SingleTableView
 
 
 from firewall.models import Host
 from firewall.models import Host
 from vm.models import Node, NodeActivity, Trait
 from vm.models import Node, NodeActivity, Trait
+from vm.tasks.vm_tasks import check_queue
 
 
 from ..forms import TraitForm, HostForm, NodeForm
 from ..forms import TraitForm, HostForm, NodeForm
 from ..tables import NodeListTable
 from ..tables import NodeListTable
@@ -107,6 +108,13 @@ class NodeDetailView(LoginRequiredMixin,
         context['trait_form'] = form
         context['trait_form'] = form
         context['graphite_enabled'] = (
         context['graphite_enabled'] = (
             settings.GRAPHITE_URL is not None)
             settings.GRAPHITE_URL is not None)
+
+        node_hostname = self.object.host.hostname
+        context['queues'] = {
+            'vmcelery.fast': check_queue(node_hostname, "vm", "fast"),
+            'vmcelery.slow': check_queue(node_hostname, "vm", "slow"),
+            'netcelery.fast': check_queue(node_hostname, "net", "fast"),
+        }
         return context
         return context
 
 
     def post(self, request, *args, **kwargs):
     def post(self, request, *args, **kwargs):

circle/vm/models/node.py

@@ -160,6 +160,8 @@ class Node(OperatedMixin, TimeStampedModel):
         """
         """
         try:
         try:
             self.get_remote_queue_name("vm", "fast")
             self.get_remote_queue_name("vm", "fast")
+            self.get_remote_queue_name("vm", "slow")
+            self.get_remote_queue_name("net", "fast")
         except:
         except:
             return False
             return False
         else:
         else: