Method Start

queue_recovery.go:61–78

Start begins the background recovery loop for stuck queued transactions.

(ctx context.Context)

// Start begins the background recovery loop for stuck queued transactions.
func (p *QueuedTransactionRecoveryProcessor) Start(ctx context.Context) {
	p.mu.Lock()
	if p.running {
		p.mu.Unlock()
		return
	}
	p.running = true
	p.stopCh = make(chan struct{})
	p.mu.Unlock()

	p.wg.Add(1)
	go func() {
		defer p.wg.Done()
		p.run(ctx)
	}()

	logrus.Info("Queued transaction recovery processor started")
}

// Stop shuts down the background recovery loop and waits for the worker goroutine to exit.
func (p *QueuedTransactionRecoveryProcessor) Stop() {