private MetricsReplicationSourceSource getSourceMetrics(String sourceId) {
    MetricsReplicationSourceFactoryImpl factory =
      (MetricsReplicationSourceFactoryImpl) CompatibilitySingletonFactory
        .getInstance(MetricsReplicationSourceFactory.class);
    return factory.getSource(sourceId);
  }
Test ReplicationSource retries startup once an uncaught exception happens during initialization
and <b>replication.source.regionserver.abort</b> is set to true.
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSource.java