Method Dispatch

pkg/redis/redis.go:668–674

Dispatch dispatches the tasks of the queue. It will continue to run until the context is done. consumerID is used to identify the consumer and should be unique for all concurrent calls to Dispatch.

(ctx context.Context, consumerID string, r redis.Cmdable)

// Dispatch dispatches the tasks of the queue. It will continue to run until the context is done.
// consumerID is used to identify the consumer and should be unique for all concurrent calls to Dispatch.
func (q *TaskQueue) Dispatch(ctx context.Context, consumerID string, r redis.Cmdable) error {
	q.consumerIDs.LoadOrStore(consumerID, struct{}{})
	if r == nil {
		r = q.Redis
	}
	return dispatchTask(ctx, r, q.Group, consumerID, q.MaxLen, q.Key, q.StreamBlockLimit)
}

// Pop calls f on the most recent task in the queue, for which timestamp is in range [0, time.Now()],
// if such is available, otherwise it blocks until it is or context is done.