pub fn new_data_receivers( model: &Arc<dyn Model>, mq_conns: &mut HashMap<String, Connection>, ch_conf: &MqChannels, ) -> Result<HashMap<String, Queue>, Box<dyn StdError>>