+ //start listener threads and register message handlers.
+ int num_threads = std::stoi(config[XappSettings::SettingName::THREADS]);
+ bool sub_required = true;
+ for(int j=0; j < num_threads; j++) {
+ std::unique_ptr<XappMsgHandler> mp_handler;
+ if(sub_required)
+ mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID], std::ref(*sub_handler));
+ else
+ mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID]);