flow rethink (two redis queue)