diff --git a/logstash-core/lib/logstash/pipelines_registry.rb b/logstash-core/lib/logstash/pipelines_registry.rb
index 86ed1eacb..51ec9b944 100644
--- a/logstash-core/lib/logstash/pipelines_registry.rb
+++ b/logstash-core/lib/logstash/pipelines_registry.rb
@@ -86,7 +86,7 @@ module LogStash
         state = @states.get(pipeline_id)
         if state.nil?
           logger.error("Attempted to terminate a pipeline that does not exists", :pipeline_id => pipeline_id)
-          @states.remote(pipeline_id)
+          @states.remove(pipeline_id)
         else
           yield(state.pipeline)
           @states.put(pipeline_id, state)