(err error)
| 52 | } |
| 53 | |
| 54 | func (c *Consumer) reportErr(err error) bool { |
| 55 | if err != nil { |
| 56 | select { |
| 57 | case c.errs <- err: |
| 58 | default: |
| 59 | } |
| 60 | return true |
| 61 | } |
| 62 | return false |
| 63 | } |
| 64 | |
| 65 | func (c *Consumer) serve(client mqDeleter, ch mqChannel) { |
| 66 | if c.reportErr(ch.Qos(c.qos, 0, false)) { |