"e2mgr/logger"
"e2mgr/models"
"e2mgr/rmrCgo"
- "e2mgr/sessions"
"strconv"
"sync"
)
type RmrService struct {
Config *RmrConfig
Messenger *rmrCgo.RmrMessenger
- E2sessions sessions.E2Sessions
RmrResponse chan *models.NotificationResponse
}
// NewRmrService instantiates a new Rmr service instance
-func NewRmrService(rmrConfig *RmrConfig, msrImpl rmrCgo.RmrMessenger, e2sessions sessions.E2Sessions, rmrResponse chan *models.NotificationResponse) *RmrService {
+func NewRmrService(rmrConfig *RmrConfig, msrImpl rmrCgo.RmrMessenger, rmrResponse chan *models.NotificationResponse) *RmrService {
return &RmrService{
Config: rmrConfig,
Messenger: msrImpl.Init("tcp:"+strconv.Itoa(rmrConfig.Port), rmrConfig.MaxMsgSize, rmrConfig.Flags, rmrConfig.Logger),
- E2sessions: e2sessions,
RmrResponse: rmrResponse,
}
}
_, err := (*r.Messenger).SendMsg(msg, r.Config.MaxMsgSize)
if err != nil {
- r.Config.Logger.Errorf("#rmr_service.SendRmrMessage - error: %#v\n", err)
return err
}
return nil
}
r.Config.Logger.Debugf("#rmr_service.SendResponse - Going to send message: %#v\n", response)
- r.SendRmrMessage(response)
+ if err := r.SendRmrMessage(response); err != nil {
+ r.Config.Logger.Errorf("#rmr_service.SendResponse - error: %#v\n", err)
+ }
}
}