A1 Message Handler update

[ric-app/hw.git] / src / hw_xapp_main.cc

diff --git a/src/hw_xapp_main.cc b/src/hw_xapp_main.cc
index 01601fb..1771797 100644 (file)
--- a/src/hw_xapp_main.cc
+++ b/src/hw_xapp_main.cc
@@ -75,22 +75,13 @@ int main(int argc, char *argv[]){
 
        //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]);
-
-               hw_xapp->register_handler(std::ref(*mp_handler));
-       }
-
        mdclog_write(MDCLOG_INFO, "Starting Listener Threads. Number of Workers = %d", num_threads);
 
-       hw_xapp->Run();
+       std::unique_ptr<XappMsgHandler> mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID]);
+       hw_xapp->start_xapp_receiver(std::ref(*mp_handler));
+
+       sleep(1);
 
-       //Delete all subscriptions if any based on Xapp Mode.
        //xapp->shutdown();
 
        while(1){