@Test public void testSimpleYampFileWithStructure() throws Exception { ConveyorConfiguration.build("CLASSPATH:test4.yml"); assertNotNull(Conveyor.byName("c4.p1.x")); Conveyor<Integer, NameLabel, String> c = Conveyor.byName("c4-1"); assertNotNull(c); CompletableFuture<String> f = c.build().id(1).createFuture(); c.part().id(1).label(NameLabel.FIRST).value("FIRST").place(); String res = f.get(); System.out.println(res); assertEquals("FIRSTpreffix-c4-1-suffix", res); CompletableFuture<String> f2 = c.build().id(2).createFuture(); c.part().id(2).label(NameLabel.LAST).value("LAST").place(); String res2 = f2.get(); System.out.println(res2); assertEquals("preffix-c4-1-suffixLAST", res2); CompletableFuture<String> f3 = c.build().id(3).createFuture(); c.part().id(2).label(NameLabel.END).value("END").place(); String res3 = f3.get(); assertEquals("preffix-c4-1-suffix", res3); assertTrue(c instanceof AssemblingConveyor); }
public static void build(String conf, String... moreConf) throws Exception { Objects.requireNonNull(conf, "At least one configuration file must be provided"); processConfFile(conf); if (moreConf != null) { for (String file : moreConf) { processConfFile(file); } } Conveyor<String, String, Conveyor> buildingConveyor = getBuildingConveyor(); Map<String,String> env = System.getenv(); env.forEach((key,value)->{ processPair(buildingConveyor, key, value); }); Properties p = System.getProperties(); p.forEach((key,value)->{ processPair(buildingConveyor, ""+key, ""+value); }); buildingConveyor.part().foreach().label("complete_configuration").value(true).place(); buildingConveyor.completeAndStop().get(); Conveyor.unRegister(buildingConveyor.getName()); }
ConveyorConfiguration { public static void build(String conf, String... moreConf) throws Exception { Objects.requireNonNull(conf, "At least one configuration file must be provided"); processConfFile(conf); if (moreConf != null) { for (String file : moreConf) { processConfFile(file); } } Conveyor<String, String, Conveyor> buildingConveyor = getBuildingConveyor(); Map<String,String> env = System.getenv(); env.forEach((key,value)->{ processPair(buildingConveyor, key, value); }); Properties p = System.getProperties(); p.forEach((key,value)->{ processPair(buildingConveyor, ""+key, ""+value); }); buildingConveyor.part().foreach().label("complete_configuration").value(true).place(); buildingConveyor.completeAndStop().get(); Conveyor.unRegister(buildingConveyor.getName()); } }
ConveyorConfiguration { public static void build(String conf, String... moreConf) throws Exception { Objects.requireNonNull(conf, "At least one configuration file must be provided"); processConfFile(conf); if (moreConf != null) { for (String file : moreConf) { processConfFile(file); } } Conveyor<String, String, Conveyor> buildingConveyor = getBuildingConveyor(); Map<String,String> env = System.getenv(); env.forEach((key,value)->{ processPair(buildingConveyor, key, value); }); Properties p = System.getProperties(); p.forEach((key,value)->{ processPair(buildingConveyor, ""+key, ""+value); }); buildingConveyor.part().foreach().label("complete_configuration").value(true).place(); buildingConveyor.completeAndStop().get(); Conveyor.unRegister(buildingConveyor.getName()); } private  ConveyorConfiguration(); }
ConveyorConfiguration { public static void build(String conf, String... moreConf) throws Exception { Objects.requireNonNull(conf, "At least one configuration file must be provided"); processConfFile(conf); if (moreConf != null) { for (String file : moreConf) { processConfFile(file); } } Conveyor<String, String, Conveyor> buildingConveyor = getBuildingConveyor(); Map<String,String> env = System.getenv(); env.forEach((key,value)->{ processPair(buildingConveyor, key, value); }); Properties p = System.getProperties(); p.forEach((key,value)->{ processPair(buildingConveyor, ""+key, ""+value); }); buildingConveyor.part().foreach().label("complete_configuration").value(true).place(); buildingConveyor.completeAndStop().get(); Conveyor.unRegister(buildingConveyor.getName()); } private  ConveyorConfiguration(); static void build(String conf, String... moreConf); @Override String toString(); }
ConveyorConfiguration { public static void build(String conf, String... moreConf) throws Exception { Objects.requireNonNull(conf, "At least one configuration file must be provided"); processConfFile(conf); if (moreConf != null) { for (String file : moreConf) { processConfFile(file); } } Conveyor<String, String, Conveyor> buildingConveyor = getBuildingConveyor(); Map<String,String> env = System.getenv(); env.forEach((key,value)->{ processPair(buildingConveyor, key, value); }); Properties p = System.getProperties(); p.forEach((key,value)->{ processPair(buildingConveyor, ""+key, ""+value); }); buildingConveyor.part().foreach().label("complete_configuration").value(true).place(); buildingConveyor.completeAndStop().get(); Conveyor.unRegister(buildingConveyor.getName()); } private  ConveyorConfiguration(); static void build(String conf, String... moreConf); @Override String toString(); static String SCRIPT_ENGINE; static String PROPERTY_PREFIX; static String PERSISTENCE_PREFIX; static String PROPERTY_DELIMITER; static long DEFAULT_TIMEOUT_MSEC; }