made updatePipelines() to not make it prone to race conditions

This commit is contained in:
Martijn van Groningen 2015-11-25 18:32:56 +01:00
parent 5d510b59c8
commit 2890432421
1 changed files with 1 additions and 1 deletions

View File

@ -122,7 +122,7 @@ public class PipelineStore extends AbstractLifecycleComponent {
return factory.create(id, config, processorFactoryRegistry);
}
void updatePipelines() throws IOException {
synchronized void updatePipelines() throws IOException {
// note: this process isn't fast or smart, but the idea is that there will not be many pipelines,
// so for that reason the goal is to keep the update logic simple.