class
MetricsReplicationSinkSourceImpl
private final MetricsReplicationSinkSource
mss
MetricsReplicationSinkSource
getSink()