lib/sqs_buffer/client.rb in sqs_buffer-0.2.1 vs lib/sqs_buffer/client.rb in sqs_buffer-0.2.2
- old
+ new
@@ -101,10 +101,10 @@
end
private
def need_to_process?
- if !buffer_empty? && (queue_full? || last_process_time_stale?)
+ if !buffer_empty? && (buffer_full? || last_process_time_stale?)
true
else
false
end
end