X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fmanagers%2Fnotification_manager.go;h=5533c52e2dedb273d6f56006ebd696c5649abc7a;hb=70a1adcdcf3ba61d0e17e89cd0b6f34f812ec878;hp=9e9673de9bc576cfeaec04a6b8aa265bbb5d77aa;hpb=8720fbfe6c21a347b3378f517a214068b4876c30;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/managers/notification_manager.go b/E2Manager/managers/notification_manager.go index 9e9673d..5533c52 100644 --- a/E2Manager/managers/notification_manager.go +++ b/E2Manager/managers/notification_manager.go @@ -30,22 +30,21 @@ import ( ) type NotificationManager struct { - rnibReaderProvider func() reader.RNibReader - rnibWriterProvider func() rNibWriter.RNibWriter + notificationHandlerProvider *providers.NotificationHandlerProvider } func NewNotificationManager(rnibReaderProvider func() reader.RNibReader, rnibWriterProvider func() rNibWriter.RNibWriter) *NotificationManager { + notificationHandlerProvider := providers.NewNotificationHandlerProvider(rnibReaderProvider, rnibWriterProvider) + return &NotificationManager{ - rnibReaderProvider: rnibReaderProvider, - rnibWriterProvider: rnibWriterProvider, + notificationHandlerProvider: notificationHandlerProvider, } } //TODO add NEWHandler with log func (m NotificationManager) HandleMessage(logger *logger.Logger, e2Sessions sessions.E2Sessions, mbuf *rmrCgo.MBuf, responseChannel chan<- *models.NotificationResponse) { - provider := providers.NewNotificationHandlerProvider(m.rnibReaderProvider, m.rnibWriterProvider) - notificationHandler, err := provider.GetNotificationHandler(mbuf.MType) + notificationHandler, err := m.notificationHandlerProvider.GetNotificationHandler(mbuf.MType) if err != nil { logger.Errorf(fmt.Sprintf("%s", err))