()
| 3562 | } |
| 3563 | |
| 3564 | func (m *Msg) checkReply() error { |
| 3565 | if m == nil || m.Sub == nil { |
| 3566 | return ErrMsgNotBound |
| 3567 | } |
| 3568 | if m.Reply == _EMPTY_ { |
| 3569 | return ErrMsgNoReply |
| 3570 | } |
| 3571 | return nil |
| 3572 | } |
| 3573 | |
| 3574 | // ackReply handles all acks. Will do the right thing for pull and sync mode. |
| 3575 | // It ensures that an ack is only sent a single time, regardless of |