@Test public void testSetMaxThreads() throws Exception { PoolingSplitJoinService service = createServiceForTests(); assertNull(service.getMaxThreads()); service.setMaxThreads(10); assertEquals(10, service.getMaxThreads().intValue()); service.setMaxThreads(null); assertNull(service.getMaxThreads()); }
public void setMaxThreads(Integer size) { maxThreads = size; }
PoolingSplitJoinService extends SplitJoinService { public void setMaxThreads(Integer size) { maxThreads = size; } }
PoolingSplitJoinService extends SplitJoinService { public void setMaxThreads(Integer size) { maxThreads = size; } PoolingSplitJoinService(); }
PoolingSplitJoinService extends SplitJoinService { public void setMaxThreads(Integer size) { maxThreads = size; } PoolingSplitJoinService(); @Override void prepare(); @Override void initService(); @Override void start(); @Override void closeService(); Integer getMaxThreads(); void setMaxThreads(Integer size); PoolingSplitJoinService withMaxThreads(Integer max); Boolean getWarmStart(); void setWarmStart(Boolean b); PoolingSplitJoinService withWarmStart(Boolean b); }
PoolingSplitJoinService extends SplitJoinService { public void setMaxThreads(Integer size) { maxThreads = size; } PoolingSplitJoinService(); @Override void prepare(); @Override void initService(); @Override void start(); @Override void closeService(); Integer getMaxThreads(); void setMaxThreads(Integer size); PoolingSplitJoinService withMaxThreads(Integer max); Boolean getWarmStart(); void setWarmStart(Boolean b); PoolingSplitJoinService withWarmStart(Boolean b);  }