lib/honeybadger/worker.rb in honeybadger-4.0.0 vs lib/honeybadger/worker.rb in honeybadger-4.1.0

@@ -17,15 +17,18 @@
     # A queue which enforces a maximum size.
     class Queue < ::Queue
       attr_reader :max_size
 
       def initialize(max_size)
+        @mutex = Mutex.new
         @max_size = max_size
         super()
       end
 
       def push(msg)
-        super unless size == max_size
+        @mutex.synchronize do
+          super unless size >= max_size
+        end
       end
     end
 
     SHUTDOWN = :__hb_worker_shutdown!