Deliveries return deliveries shipped to this consumer this channel never closed, even on disconnects
()
| 29 | // Deliveries return deliveries shipped to this consumer |
| 30 | // this channel never closed, even on disconnects |
| 31 | func (c *Consumer) Deliveries() <-chan amqp.Delivery { |
| 32 | return c.deliveries |
| 33 | } |
| 34 | |
| 35 | // Errors returns channel with AMQP channel level errors |
| 36 | func (c *Consumer) Errors() <-chan error { |
no outgoing calls