var nManager = managers.NewNotificationManager(reader.GetRNibReader, rNibWriter.GetRNibWriter)
rmrResponseChannel := make(chan *models.NotificationResponse, config.NotificationResponseBuffer)
var nManager = managers.NewNotificationManager(reader.GetRNibReader, rNibWriter.GetRNibWriter)
rmrResponseChannel := make(chan *models.NotificationResponse, config.NotificationResponseBuffer)
- rmrService := services.NewRmrService(rmrConfig, msgImpl, controllers.E2Sessions, nManager, rmrResponseChannel)
+ rmrService := services.NewRmrService(rmrConfig, msgImpl, controllers.E2Sessions, rmrResponseChannel)
+ rmrServiceReceiver := receivers.NewRmrServiceReceiver(*rmrService, nManager)
go rmrService.SendResponse()
runServer(rmrService, logger, config, rmrResponseChannel)
}
go rmrService.SendResponse()
runServer(rmrService, logger, config, rmrResponseChannel)
}
router := httprouter.New()
controller := controllers.NewNodebController(logger, rmrService, reader.GetRNibReader, rNibWriter.GetRNibWriter)
router := httprouter.New()
controller := controllers.NewNodebController(logger, rmrService, reader.GetRNibReader, rNibWriter.GetRNibWriter)
- newController := controllers.NewController(logger, reader.GetRNibReader, rNibWriter.GetRNibWriter, config, rmrResponseChannel)
+ newController := controllers.NewController(logger, rmrService, reader.GetRNibReader, rNibWriter.GetRNibWriter, config, rmrResponseChannel)
router.POST("/v1/nodeb/:messageType", controller.HandleRequest)
router.GET("/v1/nodeb-ids", controller.GetNodebIdList)
router.GET("/v1/nodeb/:ranName", controller.GetNodeb)
router.GET("/v1/health", controller.HandleHealthCheckRequest)
router.PUT("/v1/nodeb/shutdown", newController.ShutdownHandler)
router.POST("/v1/nodeb/:messageType", controller.HandleRequest)
router.GET("/v1/nodeb-ids", controller.GetNodebIdList)
router.GET("/v1/nodeb/:ranName", controller.GetNodeb)
router.GET("/v1/health", controller.HandleHealthCheckRequest)
router.PUT("/v1/nodeb/shutdown", newController.ShutdownHandler)
port := fmt.Sprintf(":%d", config.Http.Port)
if err := http.ListenAndServe(port, router); err != nil {
port := fmt.Sprintf(":%d", config.Http.Port)
if err := http.ListenAndServe(port, router); err != nil {