public function createFromConnection(Connection $connection, Identity $identity)
    {
        $channel = new Channel($connection, $identity);

        $this->channelRegistry->addChannel($channel);

        return $channel;
    }
public function createFromConnection(Connection $connection, Identity $identity)
    {
        $channel = new Channel($connection, $identity);

        $this->channelRegistry->addChannel($channel);

        return $channel;
    }
@param Connection $connection
@param Identity   $identity

@return Channel