wip_detect_broken_queues

#!/usr/bin/env python3

import requests
from requests.auth import HTTPBasicAuth
import json
import pprint
import pika
import sys

url = 'http://node1:15672/api/queues'
response = requests.get(url, auth=HTTPBasicAuth('admin', 'administrator'))
workdata = {}
if(response.ok):
        data = response.json()
        for entry in data:
                if 'messages_ram' not in entry:
                        print(entry['name'])
else:
        print(response.content)