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

	d.logger.Info("Domain DLQ handler shutting down.")
	close(d.done)
}
// Stop stops the DLQ handler
Stop stops the DLQ handler
// Stop stops the DLQ handler
func (d *dlqMessageHandlerImpl) Stop() {
	if !atomic.CompareAndSwapInt32(&d.status, common.DaemonStatusStarted, common.DaemonStatusStopped) {
		return
	}
	d.logger.Info("Domain DLQ handler shutting down.")
	close(d.done)
}
func ( d * dlqMessageHandlerImpl ) Stop ( ) { if ! atomic . CompareAndSwapInt32 ( & d . status , common . DaemonStatusStarted , common . DaemonStatusStopped ) { return } d . logger . Info ( " " ) close ( d . done ) }
Stop stops the DLQ handler
Stop stops the DLQ handler