diff --git a/common/domain/replication_queue.go b/common/domain/replication_queue.go index b4f4ae3a70b..c3440fba01f 100644 --- a/common/domain/replication_queue.go +++ b/common/domain/replication_queue.go @@ -336,13 +336,14 @@ func (q *replicationQueueImpl) emitDLQSize() { ).IncCounter( metrics.DomainReplicationQueueSizeErrorCount, ) + } else { + q.metricsClient.Scope( + metrics.DomainReplicationQueueScope, + ).UpdateGauge( + metrics.DomainReplicationQueueSizeGauge, + float64(size), + ) } - q.metricsClient.Scope( - metrics.DomainReplicationQueueScope, - ).UpdateGauge( - metrics.DomainReplicationQueueSizeGauge, - float64(size), - ) } } }