Method run

queue_recovery.go:103–119

run executes the poll loop that periodically scans for stuck queued transactions.

(ctx context.Context)

// run executes the poll loop that periodically scans for stuck queued transactions.
func (p *QueuedTransactionRecoveryProcessor) run(ctx context.Context) {
	ticker := time.NewTicker(p.pollInterval)
	defer ticker.Stop()

	for {
		select {
		case <-ctx.Done():
			logrus.Info("Queued transaction recovery processor context cancelled")
			return
		case <-p.stopCh:
			logrus.Info("Queued transaction recovery processor stop signal received")
			return
		case <-ticker.C:
			p.processBatch(ctx)
		}
	}
}

// processBatch performs one periodic stuck-queue recovery pass using the configured threshold.
func (p *QueuedTransactionRecoveryProcessor) processBatch(ctx context.Context) {