private Channel setupChannel()

in flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java [215:224]


    private Channel setupChannel(Connection connection) throws Exception {
        Channel chan = connection.createChannel();
        if (rmqConnectionConfig.getPrefetchCount().isPresent()) {
            // set the global flag for the entire channel, though shouldn't make a difference
            // since there is only one consumer, and each parallel instance of the source will
            // create a new connection (and channel)
            chan.basicQos(rmqConnectionConfig.getPrefetchCount().get(), true);
        }
        return chan;
    }