Consume used to declare consumers
(cons *Consumer)
| 54 | |
| 55 | // Consume used to declare consumers |
| 56 | func (c *Client) Consume(cons *Consumer) { |
| 57 | c.l.Lock() |
| 58 | defer c.l.Unlock() |
| 59 | c.consumers[cons] = struct{}{} |
| 60 | if ch, err := c.channel(); err == nil { |
| 61 | go cons.serve(c, ch) |
| 62 | } |
| 63 | } |
| 64 | |
| 65 | func (c *Client) deleteConsumer(cons *Consumer) { |
| 66 | c.l.Lock() |