@Test(expected=RuntimeException.class) public void invalidVEnum() throws Exception { LocalDataSource dataSource1 = new LocalDataSource(); ReadRecipeBuilder builder = new ReadRecipeBuilder(); ValueCache<Object> valueCache = new ValueCacheImpl<>(Object.class); builder.addChannel("venum<VEnum>(1, 1.0, 2.0)", valueCache); ReadRecipe recipe = builder.build(new QueueCollector<Exception>(10), new ConnectionCollector()); builder.addChannel("venum", valueCache); dataSource1.connectRead(recipe); }
@Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); @Override void connectRead(ReadRecipe readRecipe); @Override void connectWrite(WriteRecipe writeRecipe); }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); @Override void connectRead(ReadRecipe readRecipe); @Override void connectWrite(WriteRecipe writeRecipe);  }