Method Stop

lineage_worker.go:120–132

Stop gracefully stops the outbox processor. It signals the processor to stop and waits for pending work to complete.

()

// Stop gracefully stops the outbox processor.
// It signals the processor to stop and waits for pending work to complete.
func (p *LineageOutboxProcessor) Stop() {
	p.mu.Lock()
	if !p.running {
		p.mu.Unlock()
		return
	}
	p.running = false
	close(p.stopCh)
	p.mu.Unlock()

	p.wg.Wait()
	logrus.Info("Lineage outbox processor stopped")
}

// IsRunning returns whether the processor is currently running.
//