lib/sqs_buffer/client.rb in sqs_buffer-0.1.0 vs lib/sqs_buffer/client.rb in sqs_buffer-0.1.1

@@ -70,10 +70,10 @@
     def running?
       @running.true? && worker_thread_alive?
     end
 
     def worker_thread_alive?
-      !@worker_thread.nil? && @worker.alive?
+      !@worker_thread.nil? && @worker_thread.alive?
     end
 
     def last_process_time_stale?
       @last_process_time.value < Time.now.to_i - @max_wait_time.value
     end