(broker *Broker)
| 246 | } |
| 247 | |
| 248 | func (c *consumer) refBrokerConsumer(broker *Broker) *brokerConsumer { |
| 249 | c.lock.Lock() |
| 250 | defer c.lock.Unlock() |
| 251 | |
| 252 | bc := c.brokerConsumers[broker] |
| 253 | if bc == nil { |
| 254 | bc = c.newBrokerConsumer(broker) |
| 255 | c.brokerConsumers[broker] = bc |
| 256 | } |
| 257 | |
| 258 | bc.refs++ |
| 259 | |
| 260 | return bc |
| 261 | } |
| 262 | |
| 263 | func (c *consumer) unrefBrokerConsumer(brokerWorker *brokerConsumer) { |
| 264 | c.lock.Lock() |