if (mode == Mode.EMBED) {
mbean.waitOnReplicationPeerStopped(peerId);
} else {
JmxLiaison jmxLiaison = new JmxLiaison();
jmxLiaison.connect(false);
jmxLiaison.invoke(new ObjectName("LilyHBaseProxy:name=ReplicationPeer"), "waitOnReplicationPeerStopped",
peerId);
jmxLiaison.disconnect();
}
}