Dispatch on bulk records from queue to bring back true number_of_bulk_records limit

Author: nook24

src/Childs/HostcheckChild.php

@@ -122,10 +122,14 @@ public function loop() {
                     $this->StorageBackend->saveHostcheck(
                         $Hostcheck
                     );
+
+                    // Dispatch for bulk messages from queue
+                    $this->StorageBackend->dispatch();
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             $this->StorageBackend->dispatch();
 
             $this->Statistics->dispatch();

src/Childs/HoststatusChild.php

@@ -174,12 +174,16 @@ public function loop() {
                         $this->StorageBackend->saveHoststatus(
                             $Hoststatus
                         );
+
+                        // Dispatch for bulk messages from queue
+                        $this->StorageBackend->dispatch();
                     }
 
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             if ($this->storeLiveDateInArchive) {
                 $this->StorageBackend->dispatch();
             }

src/Childs/LogentryChild.php

@@ -123,10 +123,14 @@ public function loop() {
                     $this->StorageBackend->saveLogentry(
                         $Logentry
                     );
+
+                    // Dispatch for bulk messages from queue
+                    $this->StorageBackend->dispatch();
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             $this->StorageBackend->dispatch();
 
             $this->Statistics->dispatch();

src/Childs/MiscChild.php

@@ -152,9 +152,13 @@ public function loop() {
                     if (property_exists($jobJson, 'downtime')) {
                         $this->handleDowntime($jobJson);
                     }
+
+                    // Dispatch for bulk messages from queue
+                    $this->StorageBackend->dispatch();
                 }
             }
 
+            // Dispatch for bulk messages from queue
             $this->StorageBackend->dispatch();
 
             $this->Statistics->dispatch();

src/Childs/PerfdataChild.php

@@ -158,9 +158,16 @@ public function loop() {
                         }
                         $this->Statistics->increase();
                     }
+
+                    // Dispatch for bulk messages from queue
+                    foreach ($perfdataStorageBackends as $key => $backend) {
+                        $perfdataStorageBackends[$key]->dispatch();
+                    }
+
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             foreach ($perfdataStorageBackends as $key => $backend) {
                 $perfdataStorageBackends[$key]->dispatch();
             }

src/Childs/ServicecheckChild.php

@@ -122,10 +122,14 @@ public function loop() {
                     $this->StorageBackend->saveServicecheck(
                         $Servicecheck
                     );
+
+                    // Dispatch for bulk messages from queue
+                    $this->StorageBackend->dispatch();
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             $this->StorageBackend->dispatch();
 
             $this->Statistics->dispatch();

src/Childs/ServicestatusChild.php

@@ -172,12 +172,16 @@ public function loop() {
                         $this->StorageBackend->saveServicestatus(
                             $Servicestatus
                         );
+
+                        // Dispatch for bulk messages from queue
+                        $this->StorageBackend->dispatch();
                     }
 
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             if ($this->storeLiveDateInArchive) {
                 $this->StorageBackend->dispatch();
             }

src/Childs/StatechangeChild.php

@@ -118,10 +118,14 @@ public function loop() {
                     $this->StorageBackend->saveStatechange(
                         $Statechange
                     );
+
+                    // Dispatch for bulk messages from queue
+                    $this->StorageBackend->dispatch();
                     $this->Statistics->increase();
                 }
             }
 
+            // Dispatch for single messages and timeout checks
             $this->StorageBackend->dispatch();
 
             $this->Statistics->dispatch();