lib/logstash/codecs/identity_map_codec.rb in logstash-codec-multiline-3.0.9 vs lib/logstash/codecs/identity_map_codec.rb in logstash-codec-multiline-3.0.10
- old
+ new
@@ -50,17 +50,18 @@
@running.make_true
@thread = Thread.new() do
while running? do
sleep @interval
break if !running?
+ break if @listener.nil?
@listener.send(@method_symbol)
end
end
self
end
def running?
- @running.value
+ @running.true?
end
def stop
return if !running?
@running.make_false