1 files changed, 5 insertions, 2 deletions
diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php
index 4cefba113..4d89806f8 100644
--- a/lib/stompqueuemanager.php
+++ b/lib/stompqueuemanager.php
@@ -117,9 +117,12 @@ class StompQueueManager
                 }
 
                 unset($frame);
-            }
 
-            $handler->idle(0);
+                $handler->idle(QUEUE_HANDLER_HIT_IDLE);
+
+            } else {
+                $handler->idle(QUEUE_HANDLER_MISS_IDLE);
+            }
         }
 
         $this->con->unsubscribe($this->_queueName($queue));