lib/sqs_buffer/client.rb in sqs_buffer-0.2.0 vs lib/sqs_buffer/client.rb in sqs_buffer-0.2.1

- old
+ new

@@ -101,10 +101,10 @@ end private def need_to_process? - if !queue_empty? && (queue_full? || last_process_time_stale?) + if !buffer_empty? && (queue_full? || last_process_time_stale?) true else false end end