ReconfigTest.java 文件源码

private void assertLocalPeerMXBeanAttributes(QuorumPeer qp,
        String beanName, Boolean isPartOfEnsemble) throws Exception {
    Assert.assertEquals("Mismatches LearnerType!", qp.getLearnerType()
            .name(), JMXEnv.ensureBeanAttribute(beanName, "LearnerType"));
    Assert.assertEquals("Mismatches ClientAddress!",
            qp.getClientAddress().getHostString() + ":" + qp.getClientAddress().getPort(),
            JMXEnv.ensureBeanAttribute(beanName, "ClientAddress"));
    Assert.assertEquals("Mismatches LearnerType!",
            qp.getElectionAddress().getHostString() + ":" + qp.getElectionAddress().getPort(),
            JMXEnv.ensureBeanAttribute(beanName, "ElectionAddress"));
    Assert.assertEquals("Mismatches PartOfEnsemble!", isPartOfEnsemble,
            JMXEnv.ensureBeanAttribute(beanName, "PartOfEnsemble"));
    Assert.assertEquals("Mismatches ConfigVersion!", qp.getQuorumVerifier()
            .getVersion(), JMXEnv.ensureBeanAttribute(beanName,
            "ConfigVersion"));
    Assert.assertEquals("Mismatches QuorumSystemInfo!", qp
            .getQuorumVerifier().toString(), JMXEnv.ensureBeanAttribute(
            beanName, "QuorumSystemInfo"));
}