o Adding an ActiveMQ connection to messages can be sent as a hint to the consumer.HEADmaster

1 files changed, 6 insertions, 2 deletions

diff --git a/src/main/java/io/trygvis/queue/QueueExecutor.java b/src/main/java/io/trygvis/queue/QueueExecutor.java
index 468059d..88e5b46 100644
--- a/src/main/java/io/trygvis/queue/QueueExecutor.java
+++ b/src/main/java/io/trygvis/queue/QueueExecutor.java
@@ -40,9 +40,10 @@ public class QueueExecutor {
         public int ok;
         public int failed;
         public int scheduled;
+        public int missed;
 
-        public QueueStats toStats() {
-            return new QueueStats(total, ok, failed, scheduled);
+        public synchronized QueueStats toStats() {
+            return new QueueStats(total, ok, failed, missed, scheduled);
         }
     }
 
@@ -94,6 +95,9 @@ public class QueueExecutor {
 
             if (count == 0) {
                 log.warn("Missed task {}", task.id());
+                synchronized (stats) {
+                    stats.missed++;
+                }
                 return MISSED;
             }