workman使用rabbitmq消费队列时遇到问题

foreach ($subjects as $subject) {
    (new Client())->connect()->then(function (Client $client) {
        return $client->channel();
    })->then(function (Channel $channel) {
        $channel->consume(.....);
    });
}