code: def publish_queue_length(self, redis_client, port, db):
          
          for queue in redis_client.smembers('queues'):
              queue_length = redis_client.llen('queue:%s' % queue)
              self.__publish(port, db, queue, queue_length)
docs: :param redis_client: Redis client
          :param db: Redis Database index
          :param port: Redis port
          :return: Redis queue length