ConnectorTest.java 文件源码

@Test
public void testQueryMBeans() throws Exception {
    DummyTransport transport = new DummyTransport(new SequencedRequestMatcher());
    transport.addExchange(ConnectorTest.class, "queryMBeans");
    Connector connector = transport.createConnector();
    Iterator<ObjectInstance> mbeans = connector.queryMBeans(new ObjectName("WebSphere:type=Server,*"), null).iterator();
    assertTrue(mbeans.hasNext());
    ObjectInstance mbean = mbeans.next();
    assertEquals(RequiredModelMBean.class.getName(), mbean.getClassName());
    ObjectName name = mbean.getObjectName();
    assertEquals("WebSphere", name.getDomain());
    assertEquals("server1", name.getKeyProperty("name"));
    assertFalse(mbeans.hasNext());
}