(self, port, db, queue, queue_length)
:param port: Redis port
        :param db: Redis db index to report
        :param queue: Queue name to report
        :param queue_length: Queue length to report
        :return:
:param port: Redis port
        :param db: Redis db index to report
        :param queue: Queue name to report
        :param queue_length: Queue length to report
        :return:
: param port : Redis port : param db : Redis db index to report : param queue : Queue name to report : param queue_length : Queue length to report : return :
def __publish(self, port, db, queue, queue_length):
        """
        :param port: Redis port
        :param db: Redis db index to report
        :param queue: Queue name to report
        :param queue_length: Queue length to report
        :return:
        """
        metric_name_segaments = ['queue']
        cluster = self.config['cluster_prefix']
        if cluster:
            metric_name_segaments.append(cluster)
        metric_name_segaments.append(port)
        metric_name_segaments.append(str(db))
        metric_name_segaments.append(queue)
        self.publish_gauge(
            name='.'.join(metric_name_segaments), value=queue_length
        )
def __publish ( self , port , db , queue , queue_length ) : metric_name_segaments = [ 'queue' ] cluster = self . config [ 'cluster_prefix' ] if cluster : metric_name_segaments . append ( cluster ) metric_name_segaments . append ( port ) metric_name_segaments . append ( str ( db ) ) metric_name_segaments . append ( queue ) self . publish_gauge ( name = '.' . join ( metric_name_segaments ) , value = queue_length )