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;
}