code: 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
          )
docs: :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: