(name string)
| 108 | } |
| 109 | |
| 110 | func (tqs *TaskQueueSet) GetByName(name string) *TaskQueue { |
| 111 | q, ok := tqs.Queues.Get(name) |
| 112 | if !ok { |
| 113 | return nil |
| 114 | } |
| 115 | |
| 116 | return q |
| 117 | } |
| 118 | |
| 119 | func (tqs *TaskQueueSet) GetMain() *TaskQueue { |
| 120 | return tqs.GetByName(tqs.MainName) |