package queue

import (
	"context"
	"time"
)

// ProcessJob exports processJob for testing purposes
func (wp *WorkerPool) ProcessJob(job *SyncJobPayload, streamID, consumerName string) {
	wp.processJob(job, streamID, consumerName)
}

func (jq *JobQueue) PromoteDelayedRetriesForTest(ctx context.Context) error {
	return jq.promoteDelayedRetries(ctx)
}

func (jq *JobQueue) SetJobTimeoutForTest(timeout time.Duration) {
	jq.jobTimeout = timeout
}

func (jq *JobQueue) DelayedRetrySetForTest() string {
	return jq.delayedSet
}