def __create_channel(self):
        pika_connection = pika.BlockingConnection(self._pika_connection_params)
        channel = pika_connection.channel()
        self.__DEBUG("Created AMQP Connection and Channel %s" % channel)
        self.__set_recycle_for_channel(channel)
        return channel
Create a connection and a channel based on pika params
dataset/ETHPy150Open WeatherDecisionTechnologies/flask-pika/flask_pika.py/Pika.__create_channel