func NewDLQMessageHandler(
	replicationHandler ReplicationTaskExecutor,
	replicationQueue ReplicationQueue,
	logger log.Logger,
	metricsClient metrics.Client,
) DLQMessageHandler {
	return &dlqMessageHandlerImpl{
		replicationHandler: replicationHandler,
		replicationQueue:   replicationQueue,
		logger:             logger,
		metricsClient:      metricsClient,
		done:               make(chan struct{}),
		lastCount:          -1,
	}
}
// NewDLQMessageHandler returns a DLQTaskHandler instance
NewDLQMessageHandler returns a DLQTaskHandler instance
// NewDLQMessageHandler returns a DLQTaskHandler instance
func NewDLQMessageHandler(
	replicationHandler ReplicationTaskExecutor,
	replicationQueue ReplicationQueue,
	logger log.Logger,
	metricsClient metrics.Client,
) DLQMessageHandler {
	return &dlqMessageHandlerImpl{
		replicationHandler: replicationHandler,
		replicationQueue:   replicationQueue,
		logger:             logger,
		metricsClient:      metricsClient,
		done:               make(chan struct{}),
		lastCount:          -1,
	}
}
func NewDLQMessageHandler ( replicationHandler ReplicationTaskExecutor , replicationQueue ReplicationQueue , logger log . Logger , metricsClient metrics . Client , ) DLQMessageHandler { return & dlqMessageHandlerImpl { replicationHandler : replicationHandler , replicationQueue : replicationQueue , logger : logger , metricsClient : metricsClient , done : make ( chan struct { } ) , lastCount : - 1 , } }
NewDLQMessageHandler returns a DLQTaskHandler instance
NewDLQMessageHandler returns a DLQTaskHandler instance