diff --git a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
index 6c93ecd..828e1d5 100644
--- a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
+++ b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
@@ -37,10 +37,10 @@ class QueueToConsumer<T> implements IQueueToConsumer<T> {
 			boolean crashed = true;
 			try {
 				if (consumer.tryConsume(value)) {
-					crashed = false;
 					shouldAdd = false;
 					preAddQueued.decrementAndGet();
 				}
+				crashed = false;
 			} finally {
 				if (crashed) {
 					shouldAdd = false;