Exclusive set this consumer in exclusive mode
()
| 141 | |
| 142 | // Exclusive set this consumer in exclusive mode |
| 143 | func Exclusive() ConsumerOpt { |
| 144 | return func(c *Consumer) { |
| 145 | c.exclusive = true |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | // NoLocal set this consumer in NoLocal mode. |
| 150 | func NoLocal() ConsumerOpt { |
no outgoing calls