Add register a new queue for TaskQueueSet.
(queue *TaskQueue)
| 85 | |
| 86 | // Add register a new queue for TaskQueueSet. |
| 87 | func (tqs *TaskQueueSet) Add(queue *TaskQueue) { |
| 88 | tqs.Queues.Set(queue.Name, queue) |
| 89 | } |
| 90 | |
| 91 | func (tqs *TaskQueueSet) NewNamedQueue(name string, handler func(ctx context.Context, t task.Task) TaskResult, opts ...TaskQueueOption) { |
| 92 | q := NewTasksQueue( |