JmxClientDiscTest.java 文件源码

@Test
public void testRoutine() throws IOException {
    //connect to server
    final JMXConnector connection = JmxConnectionHelper.buildJmxMPConnector(JMXSERVERIP,clientObj.getConnectorSystemPort());
    MBeanServerConnection mbs = JmxServerHelper.getMBeanServer(connection);
    Assert.assertNotSame(0,mbs.getMBeanCount());
    ObjectName disc = JmxServerHelper.findObjectName(mbs,"de.b4sh.byter","Disc");
    Assert.assertNotNull(disc);
    //set up env.
    JmxClientDiscHelper.setByteTarget(mbs,disc, (long) (10* TransformValues.MEGABYTE));
    JmxClientDiscHelper.setChunkSize(mbs,disc,64000);
    JmxClientDiscHelper.setFileName(mbs,disc, StringGenerator.nextRandomString(5));
    JmxClientDiscHelper.setOutputPath(mbs,disc,testSpaceDir);
    JmxClientDiscHelper.setWriterBufferSize(mbs,disc,64000);
    JmxClientDiscHelper.setWriterImplementation(mbs,disc, WriterType.BufferedWriter.getKey());
    //start runtime
    JmxClientDiscHelper.invokeDiscTest(mbs,disc);
}