func (d *dlqMessageHandlerImpl) Count(ctx context.Context, forceFetch bool) (int64, error) {
	if forceFetch || d.lastCount == -1 {
		if err := d.fetchAndEmitDLQSize(ctx); err != nil {
			return 0, err
		}
	}
	return d.lastCount, nil
}
// Count counts domain replication DLQ messages
Count counts domain replication DLQ messages
// Count counts domain replication DLQ messages
func (d *dlqMessageHandlerImpl) Count(ctx context.Context, forceFetch bool) (int64, error) {
	if forceFetch || d.lastCount == -1 {
		if err := d.fetchAndEmitDLQSize(ctx); err != nil {
			return 0, err
		}
	}
	return d.lastCount, nil
}
func ( d * dlqMessageHandlerImpl ) Count ( ctx context . Context , forceFetch bool ) ( int64 , error ) { if forceFetch || d . lastCount == - 1 { if err := d . fetchAndEmitDLQSize ( ctx ) ; err != nil { return 0 , err } } return d . lastCount , nil }
Count counts domain replication DLQ messages
Count counts domain replication DLQ messages