- 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]);
+ mdclog_write(MDCLOG_INFO, "Starting Listener Threads. Number of Workers = %d", num_threads);
+
+ std::unique_ptr<XappMsgHandler> mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID], sub_handler);
+
+ hw_xapp->start_xapp_receiver(std::ref(*mp_handler));
+
+ sleep(1);