func (d *dlqMessageHandlerImpl) Start() {
	if !atomic.CompareAndSwapInt32(&d.status, common.DaemonStatusInitialized, common.DaemonStatusStarted) {
		return
	}

	go d.emitDLQSizeMetricsLoop()
	d.logger.Info("Domain DLQ handler started.")
}
// Start starts the DLQ handler
Start starts the DLQ handler
// Start starts the DLQ handler
func (d *dlqMessageHandlerImpl) Start() {
	if !atomic.CompareAndSwapInt32(&d.status, common.DaemonStatusInitialized, common.DaemonStatusStarted) {
		return
	}
	go d.emitDLQSizeMetricsLoop()
	d.logger.Info("Domain DLQ handler started.")
}
func ( d * dlqMessageHandlerImpl ) Start ( ) { if ! atomic . CompareAndSwapInt32 ( & d . status , common . DaemonStatusInitialized , common . DaemonStatusStarted ) { return } go d . emitDLQSizeMetricsLoop ( ) d . logger . Info ( " " ) }
Start starts the DLQ handler
Start starts the DLQ handler