lib/elastic_apm/transport/worker.rb in elastic-apm-3.10.1 vs lib/elastic_apm/transport/worker.rb in elastic-apm-3.11.0
- old
+ new
@@ -51,9 +51,10 @@
@connection = self.class.adapter.new(config)
end
attr_reader :queue, :filters, :name, :connection, :serializers
+
def work_forever
while (msg = queue.pop)
case msg
when StopMessage
debug 'Stopping worker -- %s', self