(name string, opts ...GroupOpt)
| 484 | } |
| 485 | |
| 486 | func (s *service) AddGroup(name string, opts ...GroupOpt) Group { |
| 487 | var o groupOpts |
| 488 | for _, opt := range opts { |
| 489 | opt(&o) |
| 490 | } |
| 491 | queueGroup, noQueue := resolveQueueGroup(o.queueGroup, s.Config.QueueGroup, o.qgDisabled, s.Config.QueueGroupDisabled) |
| 492 | return &group{ |
| 493 | service: s, |
| 494 | prefix: name, |
| 495 | queueGroup: queueGroup, |
| 496 | queueGroupDisabled: noQueue, |
| 497 | } |
| 498 | } |
| 499 | |
| 500 | // dispatch is responsible for calling any async callbacks |
| 501 | func (ac *asyncCallbacksHandler) run() { |
nothing calls this directly
no test coverage detected