@Test public void testInit() throws Exception { traces = new ArrayList<>(); for (int i = 0; i < TRACES_COUNT; i++) { PipelineExecutorTrace trace = mock(PipelineExecutorTrace.class); when(trace.getTaskId()).thenReturn(PIPELINE_EXECUTION_ID + Integer.toString(i)); traces.add(trace); } when(registryHelper.readEntries(registryRoot, VFSRegistryHelper.BySuffixFilter.newFilter(TRACE_SUFFIX))).thenReturn(traces); ((VFSPipelineExecutorRegistry) pipelineExecutorRegistry).init(); verify(registryHelper, times(2)).ensureDirectory(PIPELINE_EXECUTOR_REGISTRY_PATH); verify(registryHelper, times(2)).readEntries(registryRoot, VFSRegistryHelper.BySuffixFilter.newFilter(TRACE_SUFFIX)); for (Object trace : traces) { PipelineExecutorTrace result = pipelineExecutorRegistry.getExecutorTrace(((PipelineExecutorTrace) trace).getTaskId()); assertNotNull(result); assertEquals(trace, result); } }
@PostConstruct public void init() { initializeRegistryRoot(); initializeRegistry(); }
VFSPipelineExecutorRegistry extends InMemoryPipelineExecutorRegistry { @PostConstruct public void init() { initializeRegistryRoot(); initializeRegistry(); } }
VFSPipelineExecutorRegistry extends InMemoryPipelineExecutorRegistry { @PostConstruct public void init() { initializeRegistryRoot(); initializeRegistry(); } VFSPipelineExecutorRegistry(); @Inject  VFSPipelineExecutorRegistry(final VFSRegistryHelper registryHelper); }
VFSPipelineExecutorRegistry extends InMemoryPipelineExecutorRegistry { @PostConstruct public void init() { initializeRegistryRoot(); initializeRegistry(); } VFSPipelineExecutorRegistry(); @Inject  VFSPipelineExecutorRegistry(final VFSRegistryHelper registryHelper); @PostConstruct void init(); @Override void register(final PipelineExecutorTrace trace); @Override void deregister(final String taskId); }
VFSPipelineExecutorRegistry extends InMemoryPipelineExecutorRegistry { @PostConstruct public void init() { initializeRegistryRoot(); initializeRegistry(); } VFSPipelineExecutorRegistry(); @Inject  VFSPipelineExecutorRegistry(final VFSRegistryHelper registryHelper); @PostConstruct void init(); @Override void register(final PipelineExecutorTrace trace); @Override void deregister(final String taskId);  }