- // TODO: one mbuf received immediately execute goroutine
- if err != nil {
- continue //TODO log error
- }
-
- r.nManager.HandleMessage(r.config.Logger, r.e2sessions, mbuf, r.rmrResponse)
- }
-}
-
-func (r *RmrService) SendResponse(){
- for{
-
- response, ok := <-r.rmrResponse