@synchronized('lock')
    def channel(self, channel_id=None):
        """Create a new channel, or fetch the channel associated with `channel_id` if specified

        :param channel_id: channel ID number
        :type channel_id: int or None
        :return: Channel
        :rtype: amqpy.channel.Channel
        """
        try:
            return self.channels[channel_id]
        except __HOLE__:
            return Channel(self, channel_id)
dataset/ETHPy150Open veegee/amqpy/amqpy/connection.py/Connection.channel