@Override
  public void init(Context context) throws IOException {
    this.ctx = context;

    if (this.ctx != null) {
      ReplicationPeer peer = this.ctx.getReplicationPeer();
      if (peer != null) {
        peer.registerPeerConfigListener(this);
      } else {
        LOG.warn("Not tracking replication peer config changes for Peer Id " + this.ctx.getPeerId()
          + " because there's no such peer");
      }
    }
  }
A Base implementation for {@link ReplicationEndpoint}s. For internal use. Uses our internal
Guava.
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/BaseReplicationEndpoint.java