jasonmcintosh / rabbitmq-nagios-plugins Goto Github PK

#vhost = make_option("--vhost", dest="vhost", help="RabbitMQ vhost", type="string", default='%2F')
overview = ''
overview = make_option("--overview", dest="overview", help="messages, object", type="string")

def makeUrl(self):
    """
    forms self.url, a correct url to polling a rabbit queue
    """
    try:
        if self.options.use_ssl is True:
            self.url = "https://%s:%s/api/overview" % (self.options.hostname, self.options.port)
        else:
            self.url = "http://%s:%s/api/overview" % (self.options.hostname, self.options.port)
        return True
    except Exception, e:
        self.rabbit_error = 3
        self.rabbit_note = "problem forming api url:", e
    return False

def testOptions(self):
    """
    returns false if necessary options aren't present
    """
    if not self.options.hostname or not self.options.port:
        return False
    return True

def setPerformanceData(self, data, result):
    if self.options.overview == "messages":
            result.set_perf_data("messages", data['queue_totals']['messages'])
            result.set_perf_data("rate", data['queue_totals']['messages_details']['rate'])
            result.set_perf_data("messages_ready", data['queue_totals']['messages_ready'])
            result.set_perf_data("messages_unacknowledged", data['queue_totals']['messages_unacknowledged'])
    else:
            result.set_perf_data("channels", data['object_totals']['channels'])
            result.set_perf_data("connections", data['object_totals']['connections'])
            result.set_perf_data("consumers", data['object_totals']['consumers'])
            result.set_perf_data("exchanges", data['object_totals']['exchanges'])
            result.set_perf_data("queues", data['object_totals']['queues'])
    #result.set_perf_data("rabbit_error", self.rabbit_error)
    return result

def parseResult(self, data):
    if self.options.overview == "messages":
            result = self.response_for_value(data['queue_totals'])
            result.message = data['queue_totals']
    else:
            result = self.response_for_value(data['object_totals'])
            result.message = data['object_totals']

    return result