Method IsRunning

queue_recovery.go:96–100

IsRunning reports whether the recovery processor is currently active.

()

// IsRunning reports whether the recovery processor is currently active.
func (p *QueuedTransactionRecoveryProcessor) IsRunning() bool {
	p.mu.Lock()
	defer p.mu.Unlock()
	return p.running
}

// run executes the poll loop that periodically scans for stuck queued transactions.
func (p *QueuedTransactionRecoveryProcessor) run(ctx context.Context) {