class MyConsumer {

    protected $amqpChannel;
    protected $amqpConnection;

    public function connect()
    {
        // ...set $this->amqpConnection, etc
    }

    public function consume() {
        $this->amqpChannel->basic_consume('my-queue', 'my-tag', false, false, false, false, function ($msg) {
               $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
        });
        
        while (count($this->amqpChannel->callbacks)) {
            try {
                $this->amqpChannel->wait();
            } catch (\Exception $e) {
                // Suppose $e is \ErrorException with "errno=32" or "Broken pipe" in message
                $this->amqpConnection->reconnect();

                 // through all of this, $this->amqpConnection->isConnected() remains true
                 // Errors with PhpAmqpLib\Exception\AMQPProtocolConnectionException: CHANNEL_ERROR - expected 'channel.open'
                $this->consume();
            }
        }
    }
}