@Test public void testDeregister() { pipelineExecutorRegistry.register(trace); PipelineExecutorTrace result = pipelineExecutorRegistry.getExecutorTrace(PIPELINE_EXECUTION_ID); assertEquals(trace, result); pipelineExecutorRegistry.deregister(trace.getTaskId()); result = pipelineExecutorRegistry.getExecutorTrace(PIPELINE_EXECUTION_ID); assertNull(result); }
public void deregister(final String pipelineExecutionId) { checkNotNull("pipelineExecutionId", pipelineExecutionId); recordsMap.remove(pipelineExecutionId); }
InMemoryPipelineExecutorRegistry implements PipelineExecutorRegistry { public void deregister(final String pipelineExecutionId) { checkNotNull("pipelineExecutionId", pipelineExecutionId); recordsMap.remove(pipelineExecutionId); } }
InMemoryPipelineExecutorRegistry implements PipelineExecutorRegistry { public void deregister(final String pipelineExecutionId) { checkNotNull("pipelineExecutionId", pipelineExecutionId); recordsMap.remove(pipelineExecutionId); } InMemoryPipelineExecutorRegistry(); }
InMemoryPipelineExecutorRegistry implements PipelineExecutorRegistry { public void deregister(final String pipelineExecutionId) { checkNotNull("pipelineExecutionId", pipelineExecutionId); recordsMap.remove(pipelineExecutionId); } InMemoryPipelineExecutorRegistry(); @Override void register(final PipelineExecutorTrace trace); void deregister(final String pipelineExecutionId); @Override PipelineExecutorTrace getExecutorTrace(final String pipelineExecutionId); @Override Collection<PipelineExecutorTrace> getExecutorTraces(); @Override PipelineExecutorTrace getExecutorTrace(final RuntimeId runtimeId); }
InMemoryPipelineExecutorRegistry implements PipelineExecutorRegistry { public void deregister(final String pipelineExecutionId) { checkNotNull("pipelineExecutionId", pipelineExecutionId); recordsMap.remove(pipelineExecutionId); } InMemoryPipelineExecutorRegistry(); @Override void register(final PipelineExecutorTrace trace); void deregister(final String pipelineExecutionId); @Override PipelineExecutorTrace getExecutorTrace(final String pipelineExecutionId); @Override Collection<PipelineExecutorTrace> getExecutorTraces(); @Override PipelineExecutorTrace getExecutorTrace(final RuntimeId runtimeId);  }