@Test public void testSubmit() throws Exception { Properties properties = new Properties(); properties.setProperty(IntegrationTestHelper.Config.ZNODE_PATH, "/client/cli/test"); properties.setProperty(IntegrationTestHelper.Config.NUM_PARTITIONS, String.valueOf(CLUSTER_NUM_PARTITIONS)); properties.setProperty(IntegrationTestHelper.Config.ZK_SESSION_TIMEOUT, "30000"); IntegrationTestHelper helper = new IntegrationTestHelper(properties); Properties cfgProperties = createProperties(helper.getZkConnectString(), helper.getZnodePath(), helper.getZkSessionTimeout(), helper.getSslSetup()); String configFilePath = IntegrationTestHelper.createYamlConfigFile(DIR_NAME, CONFIG_FILE_NAME, cfgProperties); helper.startZooKeeperServer(); helper.startWaltzStorage(true); String storage = helper.getHost() + ":" + helper.getStorageAdminPort(); addPartitionsToStorage(CLUSTER_NUM_PARTITIONS, storage, configFilePath); helper.startWaltzServer(true); try { String[] args1 = { "validate", "--txn-per-client", "50", "--num-clients", "2", "--interval", "20", "--cli-config-path", configFilePath }; ClientCli.testMain(args1); assertFalse(errContent.toString("UTF-8").contains("Error")); String[] args2 = { "validate", "--txn-per-client", "50", "--num-clients", "2", "--interval", "20", "--cli-config-path", configFilePath }; ClientCli.testMain(args2); assertFalse(errContent.toString("UTF-8").contains("Error")); } finally { helper.closeAll(); } }
public static void testMain(String[] args) { new ClientCli(args, true).processCmd(); }
ClientCli extends SubcommandCli { public static void testMain(String[] args) { new ClientCli(args, true).processCmd(); } }
ClientCli extends SubcommandCli { public static void testMain(String[] args) { new ClientCli(args, true).processCmd(); } private  ClientCli(String[] args,  boolean useByTest); }
ClientCli extends SubcommandCli { public static void testMain(String[] args) { new ClientCli(args, true).processCmd(); } private  ClientCli(String[] args,  boolean useByTest); static void testMain(String[] args); static void main(String[] args); }
ClientCli extends SubcommandCli { public static void testMain(String[] args) { new ClientCli(args, true).processCmd(); } private  ClientCli(String[] args,  boolean useByTest); static void testMain(String[] args); static void main(String[] args);  }